Package com.bakdata.kafka

Class SenderBuilder.SimpleProducerRecord<K,V>

java.lang.Object

com.bakdata.kafka.SenderBuilder.SimpleProducerRecord<K,V>

Type Parameters:

K - type of keys

V - type of values

Enclosing class:

SenderBuilder<K,V>

public static final class SenderBuilder.SimpleProducerRecord<K,V>
extends Object

Represents a ProducerRecord without topic assignment

Constructor Summary

Constructors

Constructor	Description
SimpleProducerRecord(K key, V value)	Create a new SimpleProducerRecord without timestamp and headers
SimpleProducerRecord(K key, V value, Iterable<org.apache.kafka.common.header.Header> headers)	Create a new SimpleProducerRecord without timestamp
SimpleProducerRecord(K key, V value, Instant timestamp)	Create a new SimpleProducerRecord without headers
SimpleProducerRecord(K key, V value, Instant timestamp, Iterable<org.apache.kafka.common.header.Header> headers)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Iterable<org.apache.kafka.common.header.Header>	getHeaders()
K	getKey()
Instant	getTimestamp()
V	getValue()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

SimpleProducerRecord

public SimpleProducerRecord(K key,
 V value)

Create a new SimpleProducerRecord without timestamp and headers

Parameters:

key - key

value - value

SimpleProducerRecord

public SimpleProducerRecord(K key,
 V value,
 Instant timestamp)

Create a new SimpleProducerRecord without headers

Parameters:

key - key

value - value

timestamp - timestamp

SimpleProducerRecord

public SimpleProducerRecord(K key,
 V value,
 Iterable<org.apache.kafka.common.header.Header> headers)

Create a new SimpleProducerRecord without timestamp

Parameters:

key - key

value - value

headers - headers

SimpleProducerRecord

public SimpleProducerRecord(K key,
 V value,
 Instant timestamp,
 Iterable<org.apache.kafka.common.header.Header> headers)

Method Details

getKey

public K getKey()

getValue

public V getValue()

getTimestamp

public Instant getTimestamp()

getHeaders

public Iterable<org.apache.kafka.common.header.Header> getHeaders()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object