Skip to content
This repository has been archived by the owner on Jan 30, 2020. It is now read-only.

Add visibility of keys for kafka records in KafkaSubscriber #10

Closed
bkrahmer opened this issue Feb 16, 2017 · 1 comment
Closed

Add visibility of keys for kafka records in KafkaSubscriber #10

bkrahmer opened this issue Feb 16, 2017 · 1 comment

Comments

@bkrahmer
Copy link
Contributor

Background:
When using kafka topics which are 'compact', you hint to kafka that it can delete all records for a given key by publishing to the topic with a null body for the given key.

This data is available in the ConsumerRecord, I will add they key to the KafkaTopicInfo, since it is already passed to the event callback handler.

@bkrahmer
Copy link
Contributor Author

Fixed in 3.0.17

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant