Kafka 소비자 API가 Java 클라이언트를 사용하여 구독하지 않습니다.

카프카 : 0.10.1.0 (클라이언트 & 서버) Java 클라이언트. 동물원 : 3.4.6Kafka 소비자 API가 Java 클라이언트를 사용하여 구독하지 않습니다.

설정 : 제작자가 메시지를 게시합니다. 주제에 보낸 메시지는 구독이 작동하지 않는 동안 폴링 때 ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9093 --topic TEST.TOPIC --time -1

문제를 소비자를 사용하지만, 수동으로 할당하는 경우() 계산 - 그것은 작동합니다. 동일한 질문에 대답은 없었지만 대답은 separate thread이었습니다. 그것은 UUID 문제 일지 모르지만 우리가 단계와 세부 사항을 평가할 때 더 많은 세부 사항을 필요로합니다.

소비자 설정 : props.put ("bootstrap.servers", servers); props.put ("enable.auto.commit", ENABLE_AUTO_COMMIT);

props.put("auto.commit.interval.ms", AUTO_COMMIT_INTERVAL_MS); 
    props.put("session.timeout.ms", SESSION_TIMEOUT_MS); 
    props.put("group.id", CONSUMER_GROUP_ID); 
    props.put("key.deserializer", STRING_DESRIALIZER); 
    props.put("value.deserializer", STRING_DESRIALIZER); 
    props.put("auto.offset.reset", "earliest");

출처

2017-05-11 user1791646

명령 줄 소비자를 사용하고 있습니까? 소비자 구성을 공유 할 수 있습니까? – daniel

이 업데이트되었습니다. Java 클라이언트 (KafkaConsumer)를 사용하고 있습니다. 구독 (주제)을 사용하면 작동하지 않습니다. assign (topicPartitions) - 작동합니다. – user1791646

카프카 속성에 다음 속성이 설정되어 있습니까? 'etc/kafka/server.properties 일반적으로. listers = PLAINTEXT : // : '이것은 kafka가 plaintext (vs ssl)에서 소비자를 청취하도록 알려줍니다. – daniel

문제는 카프카 버전입니다.

0.10.2.1 (서버 및 클라이언트)로 변경되고 subscribe()는 완벽하게 작동했습니다.

출처

2017-06-09 19:15:55 user1791646

Kafka 소비자 API가 Java 클라이언트를 사용하여 구독하지 않습니다.

답변

관련 문제