У меня есть производитель, который создает сообщение в Кафке, прежде чем создавать сообщение. Я записываю эти сообщения также для целей отладки.
Теперь на стороне потребителя некоторые сообщения не принимаются. Когда я зарегистрировался в своих журналах Kibana и в Kafka, сообщение было успешно создано.
при соединении с консолью kafka я обнаружил следующее
kafka_2.11-2.1.0]$ bin/kafka-console-consumer.sh --bootstrap-server "Servier ip" --topic ConsumerTopic --from-beginning |grep “unique ID of payload(x)”
{“id”:“x”,“hotelId”:1,“date”:“2019-04-30”,“prices”:{“4”:40.0},“type”:“test”,“timestamp”:1555326236}
Я могу получить сообщение в консоли Kafka, но эти полезные данные отсутствуют в журналах Kibana и не потребляются потребителем