[jira] [Commented] (KAFKA-3800) java client can`t poll msg

[frank (JIRA)]

    [ 
https://issues.apache.org/jira/browse/KAFKA-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15319928#comment-15319928
 ] 

frank commented on KAFKA-3800:
------------------------------

i get kafka example on github. 
`Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, 
"192.168.0.180:9092");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "test_group3");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, 
"org.apache.kafka.common.serialization.IntegerDeserializer");
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, 
"org.apache.kafka.common.serialization.StringDeserializer");

        consumer = new KafkaConsumer<Integer, String>(props);`

`public void doWork() {
        System.out.println(this.topic);
        consumer.subscribe(Collections.singletonList(this.topic));
        ConsumerRecords<Integer, String> records = consumer.poll(200);
        for (ConsumerRecord<Integer, String> record : records) {
            System.out.println("Received message: (" + record.key() + ", " + 
record.value() + ") at offset " + record.offset());
        }
    }`

> 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)