轮询 Kafka 服务器的替代方案

Question

Kafka 服务器轮询 consumer/client（在 KAFKA 0.10.0.0 中）是否有替代方法？

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("foo", "bar"));   
while (true) {  
    ConsumerRecords<String, String> records = consumer.poll(100);  
    for (ConsumerRecord<String, String> record : records)  
        System.out.printf("offset = %d, key = %s, value = %s", record.offset(), record.key(), record.value());  
 }

Answer 1

没有。 Kafka 中的代理是被动的，客户端需要从那里拉取数据（不支持推送模型）。

推荐轮询循环示例。另见 http://docs.confluent.io/3.0.0/clients/consumer.html#java-client

轮询 Kafka 服务器的替代方案

Alternate for polling Kafka server

apache-kafka

kafka-consumer-api