Thanks for your reply.
I don't have any special aggregation. My only requirement is, for every
message in kafka with a particular id, write into a corresponding index in
Elasticsearch.( I might need to enrich each message before writing into ES,
but there are no aggregations on incoming stream)
Hi John,
Do you need to do any sort of grouping on the keys and aggregation? Or are you
simply using Flink to route the Kafka messages to different Elasticsearch
indices?
For the following I’m assuming the latter:
If there’s no need for aggregate computation per key, what you can do is simply
