Коллеги, а есть простой способ узнать сколько сообщений в топике

Question

pro.kafka

Iskander Ignatev

Коллеги, а есть простой способ узнать сколько сообщений в топике

лежит?

#kafka #russian #software

0

07.05.2018

1 ответов

7 просмотров

Oleg · Accepted Answer

public Optional<Map<TopicPartition, Long>> getOffsets(String topicName) { try (KafkaConsumer<String, String> consumer = createConsumer()) { List<TopicPartition> allPartitions = consumer.partitionsFor(topicName).stream() .map(info -> new TopicPartition(info.topic(), info.partition())) .collect(toList()); consumer.assign(allPartitions); Map<TopicPartition, Long> map = consumer.endOffsets(allPartitions); return Optional.of(map); } }

52 похожих чатов

Коллеги, а есть простой способ узнать сколько сообщений в топике

1 ответов

Похожие вопросы