Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class KafkaTemplate

java.lang.Object
  extended by org.springframework.integration.kafka.core.KafkaTemplate
All Implemented Interfaces:
KafkaOperations

public class KafkaTemplate
extends java.lang.Object
implements KafkaOperations

A template for executing high-level operations on a set of Kafka brokers.

Author:
Marius Bogoevici

Constructor Summary
KafkaTemplate(ConnectionFactory connectionFactory)
           
 
Method Summary
 ConnectionFactory getConnectionFactory()
           
 Result<KafkaMessageBatch> receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
          Receive data from the server.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KafkaTemplate

public KafkaTemplate(ConnectionFactory connectionFactory)
Method Detail

getConnectionFactory

public ConnectionFactory getConnectionFactory()

receive

public Result<KafkaMessageBatch> receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
Description copied from interface: KafkaOperations
Receive data from the server.

Specified by:
receive in interface KafkaOperations
Parameters:
messageFetchRequests - the set of FetchRequest
Returns:
the Result with KafkaMessageBatch

Spring Integration Kafka Support