Added support for partitioning by key (GeoEvent tag e.g. TRACK_ID)

Esri / kafka-for-geoevent

ArcGIS GeoEvent Server sample Kafka connectors for connecting to Apache Kafka message servers.

Apache License 2.0

14 stars 10 forks source link

Added support for partitioning by key (GeoEvent tag e.g. TRACK_ID) #10

Closed mshareghi closed 7 years ago

mshareghi commented 7 years ago

Added optional support for partitioning using a GeoEvent tag as the partition key. The default tag is used is TRACK_ID. This change supports stateful GeoEvent processing across multiple consumers.