[
https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319975#comment-15319975
]
Ewen Cheslack-Postava commented on KAFKA-3800:
----------------------------------------------
This code will only read new messages written after the program starts because
the default consumer config that controls where to start reading data defaults
to "latest" if there is no existing offset (i.e. when you first start a
consumer and it doesn't know where to start reading it will start at *the end*
of the log, after all the existing messages)
http://docs.confluent.io/3.0.0/clients/javadocs/constant-values.html#org.apache.kafka.clients.consumer.ConsumerConfig.AUTO_OFFSET_RESET_DOC
Maybe try adding
props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
to the configuration and re-running (making sure to either change the group ID
or making sure you're working from a brand new cluster since enable.auto.commit
is also enabled by default, so if you ran this app once before, it has probably
committed offsets already and will not attempt to reset based on the
auto.offset.reset setting).
> java client can`t poll msg
> --------------------------
>
> Key: KAFKA-3800
> URL: https://issues.apache.org/jira/browse/KAFKA-3800
> Project: Kafka
> Issue Type: Bug
> Components: consumer
> Affects Versions: 0.9.0.1
> Environment: java8,win7 64
> Reporter: frank
> Assignee: Neha Narkhede
>
> i use hump topic name, after poll msg is null.eg: Test_4 why?
> all low char is ok. i`m try nodejs,kafka-console-consumers.bat is ok
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
