THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Method signature | Description |
|---|---|
void acknowledge(ConsumerRecord record) | Acknowledge successful delivery of a record returned on the last poll(Duration). The acknowledgement is committed on the next commitSync() or commitAsync() call. |
void acknowledge(ConsumerRecord record, AcknowledgementType AcknowledgeType type) | Acknowledge delivery of a record returned on the last poll(Duration) indicating whether it was processed successfully. The acknowledgement is committed on the next commitSync() or commitAsync() call. |
void close() | Close the consumer, waiting for up to the default timeout of 30 seconds for any needed cleanup. |
void close(Duration timeout) | Tries to close the consumer cleanly within the specified timeout. |
void commitAsync() | Commits the acknowledgements for the records returned. |
void commitSync() | Commits the acknowledgements for the records returned. |
void commitSync(Duration timeout) | Commits the acknowledgements for the records returned. |
Map<MetricName, ? extends Metric> metrics() | Get the metrics kept by the consumer. |
List<PartitionInfo> partitionsFor(String topic) | Get metadata about the partitions for a given topic. |
List<PartitionInfo> partitionsFor(String topic, Duration timeout) | Get metadata about the partitions for a given topic. |
ConsumerRecords<K,V> poll(Duration timeout) | Fetch data for the topics or partitions specified using the subscribe API. |
void subscribe(Collection<String> topics) | Subscribe to the given list of topics to get dynamically assigned partitions. |
Set<String> subscription() | Get the current subscription. |
void unsubscribe() | Unsubscribe from topics currently subscribed with subscribe(Collection) . |
void wakeup() | Wakeup the consumer. |
...