Github user james-sirota commented on the issue:
https://github.com/apache/metron/pull/1030
When I try:
[Stellar]>>> KAFKA_PUT("mytopic", "{ message! }")
[{partition=0, offset=0, topic=mytopic, timestamp=1528428506817}]
[Stellar]>>> KAFKA_PUT("mytopic", "{ message! }")
[{partition=0, offset=1, topic=mytopic, timestamp=1528428552606}]
[Stellar]>>> KAFKA_TAIL("mytopic")
[]
[Stellar]>>> KAFKA_GET("mytopic")
[]
So nothing is pulled back. But the topic and the data does exist:
/usr/hdp/current/kafka-broker/bin/kafka-console-consumer.sh --topic mytopic
--zookeeper localhost:2181 --from-beginning
{ message! }
{ message! }
---
