如何在org.apache.kafka.streams.TopologyTestDriver中使用自定义分区程序类？
org.apache.kafka.streams.TopologyTestDriver在内...
Kafka分区的大小并写入没有可用磁盘空间的主题
出于企业解决方案的目的，我开始学习Kafka。 在阅读...
当我们在运行时增加分区时，Kafka如何保证消息顺序？
我是kafka的新手，当我阅读Kafka文档时，我意识到带...
如果我要向其发送消息的分区的磁盘已满，Kafka是否会在同一主题中选择其他分区？
我的主题有3个分区（在3个不同的代理中）。我想向特...
Kafka使用者是否从分区中的活动段中读取消息？
让我们说我有一个分区（partition-0），其中包含4个...
在kafka分区中压缩的偏移量会怎样？
让我们说，我有一个带有两个对数段的partion-0。第一...
消耗多个分区的kafka批处理
我知道Kafka可以批量提取事件。 我正在尝试了解这种...
Kafka自定义分区程序可在使用者之间实现均匀的负载平衡
我有1个主题，其中K个分区，但是消息的大小各不相同...
Kafka日志目录中文件的总大小小于其大小的总和
我正在测试一个Kafka生产者应用程序，并注意到Kafka...
kafka是否支持数百万个分区？
如果一个主题有数百万个分区，我们会遇到任何问题吗...
Kafka log.segment.bytes 与 log.retention.hours
我正在阅读《Kafka：权威指南》第一版一书，以了解代...
Kafka 中相同主题的相同服务消费和发布
在这里，我描述了我正在使用 Kafka 开发解决方案的业...
如何在kafka中创建分区
我刚刚在新集群上升级了 kafka，并将其添加到我的 k...
Spring Boot kafka：微服务多实例、并发与分区
我有一个关于在 kafka 中发布和读取消息的方式的问题...