Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Alternate for polling Kafka server

Is there any alternate for Kafka server polling for consumer/client (in 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());  
 }
like image 858
gsc0441 Avatar asked Oct 25 '25 21:10

gsc0441


1 Answers

No. Brokers in Kafka are passive and clients need to pull data from there (a push model is not supported).

The poll loop example is recommended. See also http://docs.confluent.io/3.0.0/clients/consumer.html#java-client

like image 163
Matthias J. Sax Avatar answered Oct 28 '25 17:10

Matthias J. Sax



Donate For Us

If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!