I'm using logstash to ingest data from Redshift table and put into Kafka.
It works great. But how to use input field as Kafka's key?
It seems like it doesnt work. Tried to use message_key, but no way
I'm using logstash to ingest data from Redshift table and put into Kafka.
It works great. But how to use input field as Kafka's key?
It seems like it doesnt work. Tried to use message_key, but no way
© 2020. All Rights Reserved - Elasticsearch
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant logo are trademarks of the Apache Software Foundation in the United States and/or other countries.