public interface KafkaOperations
| Modifier and Type | Method and Description |
|---|---|
Result<KafkaMessageBatch> |
receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
Receive data from the server.
|
Result<KafkaMessageBatch> receive(java.lang.Iterable<FetchRequest> messageFetchRequests)
messageFetchRequests - the set of FetchRequest