You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@metron.apache.org by james-sirota <gi...@git.apache.org> on 2018/06/08 03:41:18 UTC

[GitHub] metron issue #1030: METRON-1573 Enhance KAFKA_* functions to return partitio...

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! }



---