我正在尝试使用包含连接的kafka streams应用程序对kafka主题中的数据进行反处理。其中一个要加入的流在相应的主题中每单位时间具有更大的数据量。我希望控制各个主题的消耗，以便在单个主题中从每个主题获得大致相同的事件时间戳 consumer.poll() . 但是，似乎没有任何方法可以控制 KafkaConsumer 备份源流。有什么办法吗？如有任何见解，我们将不胜感激。
consumer.poll()
KafkaConsumer
abithluo1#
目前，Kafka无法控制对生产者和消费者的利率限制。参考：https://cwiki.apache.org/confluence/display/kafka/kip-13+-+quotas但是，如果使用apachespark作为流处理平台，则可以限制kafka接收器的输入速率。
1条答案
按热度按时间abithluo1#
目前，Kafka无法控制对生产者和消费者的利率限制。
参考：https://cwiki.apache.org/confluence/display/kafka/kip-13+-+quotas
但是，如果使用apachespark作为流处理平台，则可以限制kafka接收器的输入速率。