1
저는 Kafka 0.9.1 새로운 소비자 API를 사용하고 있습니다. 소비자는 파티션에 수동으로 할당됩니다. 이 소비자에게는 그 진전 (지연을 의미)을보고 싶습니다. 내가 속성으로 그룹 ID 소비자 튜토리얼을 추가하기 때문에, 내가 (여기 설명) 내가Kafka : 파티션에 할당 된 소비자에 대한 지연 모니터링 주제
불행하게도, 내 소비자 그룹의 세부 사항이 사용 표시되지 않습니다 명령
bin/kafka-consumer-groups.sh --new-consumer --describe --group consumer-tutorial --bootstrap-server localhost:9092
를 사용할 수 있다고 가정 위의 명령. 따라서 나는 소비자의 진전 상황을 모니터 할 수 없다. 위에서 설명한 시나리오 (수동으로 할당 된 파티션)에서 지연을 모니터링하려면 어떻게합니까?
코드는 다음 kafka-consumer-groups.sh 명령에서
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "consumer-tutorial");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
String topic = "my-topic";
TopicPartition topicPartition = new TopicPartition(topic, 0);
consumer.assign(Arrays.asList(topicPartition));
consumer.seekToBeginning(topicPartition);
try {
while (true) {
ConsumerRecords<String, String> records = consumer.poll(1000);
for (ConsumerRecord<String, String> record : records)
System.out.println(record.offset() + ": " + record.value());
consumer.commitSynch();
}
} finally {
consumer.close();
}
배경 정보는 어디에 있습니까? 링크가 보이지 않습니다. – PhillipAMann