Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何删除消费者已经消费过的数据?卡夫卡
我正在kafka中进行数据复制 但是 kafka 日志文件的大小增长得非常快 一天的大小达到 5 GB 作为这个问题的解决方案 我想立即删除已处理的数据 我正在 AdminClient 中使用删除记录方法来删除偏移量 但是当我查看日志文件时
Java
ApacheKafka
offset
kafkatopic
Apache Kafka 中的分区领导者是什么?
kafka领导者是自己分区还是经纪人 我最初的理解是它们是充当读 写代理的分区 然后将它们的值传递给 ISR 然而最近我听到有人提到它们 好像它们发生在 经纪人 级别 因此我很困惑 我知道还有其他帖子旨在回答这个问题 但那里的答案没有帮助
ApacheKafka
Broker
kafkatopic
leader
kafkapartition