Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Kafka Message Key discarded; Channel ID instead? #12

Open
amihalik opened this issue Jun 6, 2017 · 0 comments
Open

Kafka Message Key discarded; Channel ID instead? #12

amihalik opened this issue Jun 6, 2017 · 0 comments

Comments

@amihalik
Copy link

amihalik commented Jun 6, 2017

A Kafka Message (or Record) is composed of a Key, Value, and Timestamp and there are currently use cases where data in the Message Key is needed to properly process the Message Value. In these cases, the GeoEvent Adapter will require both the Message Key and Message Value to create a GeoEvent.

The current KafkaInboundTransport drops the Message Key on the floor. I propose that the Message Key is used as the Channel ID. If we pass the Message Key as the Channel ID, the GeoEvent Adapter will have both the Message Key and Value when it deserializes the GeoEvent.

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

No branches or pull requests

1 participant