Outbound Transport Partitioning by Key tag

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

Closed mshareghi closed 7 years ago

mshareghi commented 7 years ago

Added optional support for partitioning using a GeoEvent tag as the Producer key
Typical tag used is TRACK_ID, for supporting stateful processing for each track.
Default value is empty string (Kafka round robin partitioning) to preserve backwards compatibility.
Added transport property called "Geoevent Key Tag" to support tag designation.