org.springframework.kafka.core

Interface KafkaOperations<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Known Implementing Classes:

KafkaTemplate

public interface KafkaOperations<K,V>

The basic Kafka operations contract.

Author:

Marius Bogoevici, Gary Russell

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(int partition, K key, V data) Send the data to the default topic with the provided key and partition.
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(K key, V data) Send the data to the default topic with the provided key and no partition.
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(java.lang.String topic, int partition, K key, V data) Send the data to the provided topic with the provided key and partition.
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(java.lang.String topic, K key, V data) Send the data to the provided topic with the provided key and no partition.
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(java.lang.String topic, V data) Send the data to the provided topic with no key or partition.
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata>	convertAndSend(V data) Send the data to the default topic with no key or partition.
void	flush() Flush the producer.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(int partition, K key, V data) Send the data to the default topic with the provided key and partition.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(K key, V data) Send the data to the default topic with the provided key and no partition; wait for result.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(java.lang.String topic, int partition, K key, V data) Send the data to the provided topic with the provided key and partition; wait for result.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(java.lang.String topic, K key, V data) Send the data to the provided topic with the provided key and no partition; wait for result.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(java.lang.String topic, V data) Send the data to the provided topic with no key or partition.; wait for result.
org.apache.kafka.clients.producer.RecordMetadata	syncConvertAndSend(V data) Send the data to the default topic with no key or partition; wait for result.

Method Detail

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(V data)

Send the data to the default topic with no key or partition.

Parameters:

data - The data.

Returns:

a Future for the RecordMetadata.

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(K key,
                                                                                             V data)

Send the data to the default topic with the provided key and no partition.

Parameters:

key - the key.

data - The data.

Returns:

a Future for the RecordMetadata.

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(int partition,
                                                                                             K key,
                                                                                             V data)

Send the data to the default topic with the provided key and partition.

Parameters:

partition - the partition.

key - the key.

data - the data.

Returns:

a Future for the RecordMetadata.

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(java.lang.String topic,
                                                                                             V data)

Send the data to the provided topic with no key or partition.

Parameters:

topic - the topic.

data - The data.

Returns:

a Future for the RecordMetadata.

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(java.lang.String topic,
                                                                                             K key,
                                                                                             V data)

Send the data to the provided topic with the provided key and no partition.

Parameters:

topic - the topic.

key - the key.

data - The data.

Returns:

a Future for the RecordMetadata.

convertAndSend

java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> convertAndSend(java.lang.String topic,
                                                                                             int partition,
                                                                                             K key,
                                                                                             V data)

Send the data to the provided topic with the provided key and partition.

Parameters:

topic - the topic.

partition - the partition.

key - the key.

data - the data.

Returns:

a Future for the RecordMetadata.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the default topic with no key or partition; wait for result.

Parameters:

data - The data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(K key,
                                                                    V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the default topic with the provided key and no partition; wait for result.

Parameters:

key - the key.

data - The data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(int partition,
                                                                    K key,
                                                                    V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the default topic with the provided key and partition. wait for result.

Parameters:

partition - the partition.

key - the key.

data - the data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(java.lang.String topic,
                                                                    V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the provided topic with no key or partition.; wait for result.

Parameters:

topic - the topic.

data - The data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(java.lang.String topic,
                                                                    K key,
                                                                    V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the provided topic with the provided key and no partition; wait for result.

Parameters:

topic - the topic.

key - the key.

data - The data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

syncConvertAndSend

org.apache.kafka.clients.producer.RecordMetadata syncConvertAndSend(java.lang.String topic,
                                                                    int partition,
                                                                    K key,
                                                                    V data)
                                                             throws java.lang.InterruptedException,
                                                                    java.util.concurrent.ExecutionException

Send the data to the provided topic with the provided key and partition; wait for result.

Parameters:

topic - the topic.

partition - the partition.

key - the key.

data - the data.

Returns:

a RecordMetadata.

Throws:

java.util.concurrent.ExecutionException - execution exception while awaiting result.

java.lang.InterruptedException - thread interrupted while awaiting result.

flush

void flush()

Flush the producer.