public class KafkaTemplate extends java.lang.Object implements KafkaOperations
| Constructor and Description |
|---|
KafkaTemplate(ConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
ConnectionFactory |
getConnectionFactory() |
Result<KafkaMessageBatch> |
receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
Receive data from the server.
|
public KafkaTemplate(ConnectionFactory connectionFactory)
public ConnectionFactory getConnectionFactory()
public Result<KafkaMessageBatch> receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
KafkaOperationsreceive in interface KafkaOperationsmessageFetchRequests - the set of FetchRequest