卡夫卡分区偏移量分布不均
在负载测试后的一个测试环境中，我的场景中我们的ka...
我如何让Kafka根据提供的保留期限删除日志
我有一个kafka集群或3个在AWS EC2实例上运行的代理。...
通过Kafka紧凑主题实现GDPR合规性
我想问您一些关于apache kafka和紧凑主题的问题。我...
如何在Kafka中实时保存实时数据？
想象一下，源系统/生产者/ Kafka集群之间存在一些故...
如何在单个kafka主题的所有分区中写入相同的消息？
我有一个主题，假设名称为“ Test”。假设它有4个分...
Kubernetes集群-无法从在多VM k8s集群中的另一个Pod中运行的Spring Boot服务访问在Pod中运行的Kafka代理
我有一个在多VM环境（私有云-具有我们自己的Kuberne...
为什么Kafka使用者外壳无法使用.Net Core控制台中我ProducerBuilder类的消息？
我已经在Ubuntu上安装了Kafka并设法仅使用shell文件...
Spring Batch中的kafka生产者，多线程编写者将重复消息发送到主题
我正在使用Writer的Spring Batch（如果条件失败，也...
Kafka Stream使用相同的谓词将消息发送到多个分支
我需要给两个不同的分支提供相同的<key，value&g...
卡夫卡生产者即使设置了acks = all也丢失了消息
这是我的配置： <pre><code>props.put(...
应用中多生产者方案的理想方法
我有一个场景，其中多个孤立的源（此后称为Jobs）需...
并行从单流主题写入不同的主题
我有一个流，它使消息映射到两个不同的map（）调用，...
Avro Producer发送没有密钥架构的密钥
我在Python 2.7中使用Avro Producer。我需要发送带有...
带有2个分区的Kafka主题“丢失”的消息，并通过密钥发送，而具有1个分区的消息则可以
我正在使用运行在python 3.8上的Kafkapython，并从C...