K - the key type.V - the value type.public interface KafkaOperations<K,V>
ListenableFutures.| Modifier and Type | Method and Description |
|---|---|
void |
flush()
Flush the producer.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
send(org.springframework.messaging.Message<?> message)
Send a message with routing information in message headers.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
send(java.lang.String topic,
int partition,
K key,
V data)
Send the data to the provided topic with the provided key and partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
send(java.lang.String topic,
int partition,
V data)
Send the data to the provided topic with the provided partition and no key.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
send(java.lang.String topic,
K key,
V data)
Send the data to the provided topic with the provided key and no partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
send(java.lang.String topic,
V data)
Send the data to the provided topic with no key or partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
sendDefault(int partition,
K key,
V data)
Send the data to the default topic with the provided key and partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
sendDefault(K key,
V data)
Send the data to the default topic with the provided key and no partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> |
sendDefault(V data)
Send the data to the default topic with no key or partition.
|
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(V data)
data - The data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(K key, V data)
key - the key.data - The data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(int partition, K key, V data)
partition - the partition.key - the key.data - the data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic, V data)
topic - the topic.data - The data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic, K key, V data)
topic - the topic.key - the key.data - The data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic, int partition, V data)
topic - the topic.partition - the partition.data - The data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic, int partition, K key, V data)
topic - the topic.partition - the partition.key - the key.data - the data.SendResult.org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(org.springframework.messaging.Message<?> message)
message - the message to send.SendResult.KafkaHeaders.TOPIC,
KafkaHeaders.PARTITION_ID,
KafkaHeaders.MESSAGE_KEYvoid flush()