|
Spring Integration Kafka Support | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.integration.kafka.core.KafkaTemplate
public class KafkaTemplate
A template for executing high-level operations on a set of Kafka brokers.
| 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 |
|---|
public KafkaTemplate(ConnectionFactory connectionFactory)
| Method Detail |
|---|
public ConnectionFactory getConnectionFactory()
public Result<KafkaMessageBatch> receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
KafkaOperations
receive in interface KafkaOperationsmessageFetchRequests - the set of FetchRequest
|
Spring Integration Kafka Support | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||