THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Method signature | Description |
|---|---|
KafkaShareConsumer(Map<String, Object> configs) | Constructor |
KafkaShareConsumer(Properties properties) | Constructor |
KafkaShareConsumer(Map<String, Object> configs, | Constructor |
KafkaShareConsumer(Properties properties, | Constructor |
void acknowledge(ConsumerRecord record) | Acknowledge successful delivery of a record returned on the last poll(Duration). The acknowledgement is committed on the next commitSync(), commitAsync() or poll(Duration) call. |
void acknowledge(ConsumerRecord record, 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(), commitAsync() or poll(Duration) call. |
Uuid clientInstanceId(Duration timeout) | Determines the client's unique client instance ID used for telemetry. |
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. |
Map<TopicIdPartition, Optional<KafkaException>> commitSync() | Commits the acknowledgements for the records returned. |
Map<TopicIdPartition, Optional<KafkaException>> commitSync(Duration timeout) | Commits the acknowledgements for the records returned. |
Map<MetricName, ? extends Metric> metrics() | Get the metrics kept by the consumer. |
ConsumerRecords<K,V> poll(Duration timeout) | Fetch data for the topics or partitions specified using the subscribe API. |
void setAcknowledgeCommitCallback(AcknowledgeCommitCallback callback) | Sets the acknowledge commit callback which can be used to handle acknowledgement completion. |
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. |
...