Kafka消费者只给出第一个产生的信息

Question

我对Kafka很陌生。我使用的是Kafka0.9.0.0客户端for Java。在使用特定主题的数据时，当我启动生产者-消费者java项目时，我每次都得到相同的消息（这是第一次发布的消息）。

我的要求是生成一些消息并使用它，检查两个消息是否相同。

KafkaConsumer<String, String> newConsumer = new KafkaConsumer<String, String>(properties);
newConsumer.subscribe(Collections.singletonList(props.getProperty("monitoring.topic")));

String consumerRecord = "";
ConsumerRecords<String, String> consumerRecords = newConsumer.poll(120000);

for (ConsumerRecord<String, String> record : consumerRecords) {
    logger.info("Found message  for  {} {} {}", adapter, record.key(), record.value());
    System.out.println("consumerMessage : " + record.value());
    JSONObject jsonConsumerMessage = (JSONObject) (parser.parse(record.value()));

    Long offset = record.offset();
    System.out.println("Offset of this record is " + offset);
    String UUIDProducer = message.get("UUID").toString();

    String UUIDConsumer = jsonConsumerMessage.get("UUID").toString();
    System.out.println("UUIDProducer :  " + UUIDProducer);
    System.out.println("UUIDConsumer :  " + UUIDConsumer);
    if (UUIDProducer.equals(UUIDConsumer)) {
        return true;
    } else
        return false;
}

有谁能给我指点一下吗？

Answer 1

在for循环中返回true和false值是我的愚蠢错误。它会导致当第一条消息从主题传来时循环就会出现。