org.springframework.kafka.core

Interface KafkaOperations<K,V>

Type Parameters:

K - the key type.

V - the value type. If the Kafka topic is set with CreateTime all send operations will use the user provided time if provided, else KafkaProducer will generate one If the topic is set with LogAppendTime then the user provided timestamp will be ignored and instead will be the Kafka broker local time when the message is appended

All Known Implementing Classes:

KafkaTemplate

public interface KafkaOperations<K,V>

The basic Kafka operations contract returning ListenableFutures.

Author:

Marius Bogoevici, Gary Russell, Biju Kunjummen

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	KafkaOperations.OperationsCallback<K,V,T> A callback for executing arbitrary operations on the KafkaOperations.
static interface	KafkaOperations.ProducerCallback<K,V,T> A callback for executing arbitrary operations on the Producer.

Method Summary

Modifier and Type	Method and Description
<T> T	execute(KafkaOperations.ProducerCallback<K,V,T> callback) Execute some arbitrary operation(s) on the producer and return the result.
<T> T	executeInTransaction(KafkaOperations.OperationsCallback<K,V,T> callback) Execute some arbitrary operation(s) on the operations and return the result.
void	flush() Flush the producer.
java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric>	metrics() See Producer.metrics().
java.util.List<org.apache.kafka.common.PartitionInfo>	partitionsFor(java.lang.String topic) See Producer.partitionsFor(String).
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(org.apache.kafka.clients.producer.ProducerRecord<K,V> record) Send the provided ProducerRecord.
org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>>	send(java.lang.String topic, java.lang.Integer 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, java.lang.Integer partition, java.lang.Long timestamp, 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, 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(java.lang.Integer 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(java.lang.Integer partition, java.lang.Long timestamp, 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.
void	sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets) When running in a transaction (usually synchronized with some other transaction), send the consumer offset(s) to the transaction.
void	sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, java.lang.String consumerGroupId) When running in a transaction (usually synchronized with some other transaction), send the consumer offset(s) to the transaction.

Method Detail

sendDefault

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(V data)

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

Parameters:

data - The data.

Returns:

a Future for the SendResult.

sendDefault

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.

Parameters:

key - the key.

data - The data.

Returns:

a Future for the SendResult.

sendDefault

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(java.lang.Integer 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 SendResult.

sendDefault

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendDefault(java.lang.Integer partition,
                                                                                  java.lang.Long timestamp,
                                                                                  K key,
                                                                                  V data)

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

Parameters:

partition - the partition.

timestamp - the timestamp of the record.

key - the key.

data - the data.

Returns:

a Future for the SendResult.

Since:

1.3

send

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.

Parameters:

topic - the topic.

data - The data.

Returns:

a Future for the SendResult.

send

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.

Parameters:

topic - the topic.

key - the key.

data - The data.

Returns:

a Future for the SendResult.

send

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic,
                                                                           java.lang.Integer 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 SendResult.

send

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(java.lang.String topic,
                                                                           java.lang.Integer partition,
                                                                           java.lang.Long timestamp,
                                                                           K key,
                                                                           V data)

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

Parameters:

topic - the topic.

partition - the partition.

timestamp - the timestamp of the record.

key - the key.

data - the data.

Returns:

a Future for the SendResult.

Since:

1.3

send

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)

Send the provided ProducerRecord.

Parameters:

record - the record.

Returns:

a Future for the SendResult.

Since:

1.3

send

org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> send(org.springframework.messaging.Message<?> message)

Send a message with routing information in message headers. The message payload may be converted before sending.

Parameters:

message - the message to send.

Returns:

a Future for the SendResult.

See Also:

KafkaHeaders.TOPIC, KafkaHeaders.PARTITION_ID, KafkaHeaders.MESSAGE_KEY

partitionsFor

java.util.List<org.apache.kafka.common.PartitionInfo> partitionsFor(java.lang.String topic)

See Producer.partitionsFor(String).

Parameters:

topic - the topic.

Returns:

the partition info.

Since:

1.1

metrics

java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics()

See Producer.metrics().

Returns:

the metrics.

Since:

1.1

execute

<T> T execute(KafkaOperations.ProducerCallback<K,V,T> callback)

Execute some arbitrary operation(s) on the producer and return the result.

Type Parameters:

T - the result type.

Parameters:

callback - the callback.

Returns:

the result.

Since:

1.1

executeInTransaction

<T> T executeInTransaction(KafkaOperations.OperationsCallback<K,V,T> callback)

Execute some arbitrary operation(s) on the operations and return the result. The operations are invoked within a local transaction and do not participate in a global transaction (if present).

Type Parameters:

T - the result type.

Parameters:

callback - the callback.

Returns:

the result.

Since:

1.1

flush

void flush()

Flush the producer.

sendOffsetsToTransaction

void sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)

When running in a transaction (usually synchronized with some other transaction), send the consumer offset(s) to the transaction. The group id is obtained from ProducerFactoryUtils.getConsumerGroupId(). It is not necessary to call this method if the operations are invoked on a listener container thread since the container will take care of sending the offsets to the transaction.

Parameters:

offsets - The offsets.

Since:

1.3

sendOffsetsToTransaction

void sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                              java.lang.String consumerGroupId)

When running in a transaction (usually synchronized with some other transaction), send the consumer offset(s) to the transaction. It is not necessary to call this method if the operations are invoked on a listener container thread since the container will take care of sending the offsets to the transaction.

Parameters:

offsets - The offsets.

consumerGroupId - the consumer's group.id.

Since:

1.3