要求是使用scala或spark编程计算kafka主题中的消息数。我是新的两个编程，所以我不知道如何才能做到这一点。有谁能帮我的代码或指导我如何才能实现它。
vulvrdjw1#
一个给定问题的方法 org.apache.kafka.clients.consumer.KafkaConsumer 是： beginningOffsets(Collection<TopicPartition>) 以及 endOffsets(Collection<TopicPartition>) .您需要记住，kafka代理可以删除消息，这就是为什么需要开始消息。
org.apache.kafka.clients.consumer.KafkaConsumer
beginningOffsets(Collection<TopicPartition>)
endOffsets(Collection<TopicPartition>)
1条答案
按热度按时间vulvrdjw1#
一个给定问题的方法
org.apache.kafka.clients.consumer.KafkaConsumer是：beginningOffsets(Collection<TopicPartition>)以及endOffsets(Collection<TopicPartition>).您需要记住，kafka代理可以删除消息，这就是为什么需要开始消息。