Можно ли повторно использовать Java Kafka Consumer? - PullRequest
Новая
       15

Можно ли повторно использовать Java Kafka Consumer?

0 голосов
/ 16 марта 2019

Я хочу иметь пул потребителей и повторно использовать каждого потребителя. Это правильно? 

KafkaConsumer consumer = createConsumer();
TopicPartition topicPartition = new TopicPartition("topic", 2);
consumer.assign(List.of(topicPartition));
consumer.seek(topicPartition, 41);

ConsumerRecords records = consumer.poll(0);
// use records...

// reuse kafka consumer 
consumer.unsubscribe();

topicPartition = new TopicPartition("topic", 1);
consumer.assign(List.of(topicPartition));
consumer.seek(topicPartition, 8);

records = consumer.poll(0);
// use records...

Или мне каждый раз создавать нового потребителя, когда мне это нужно?

...