apache-kafka

英文: create a map using key value of ConsumerRecord kafka 问题 以下是您要翻译的部分： 我正在使用KafkaConsumer从一系列Kafka主...

英文: Why do I get a ValueError in my Kafka Consumer if I seek to another position? 问题 I'll provide a ...

英文: golang undefined module, which is downloaded correctly 问题 我按照kafka go示例项目上的说明进行操作。在使用以下命令获取模块后： ...

英文: Can Kafka brokers connect through more than one port 问题 我们有很多微服务连接到一个 Kafka 代理集群，作为企业消息总线。 在我们的可...

英文: How to check a partition is assigned in Kafka 问题 我正在尝试找到一种在执行某项操作之前检查是否已分配分区的方法。我们知道通过检查 consume...

英文: Is there a way to encrypt kafka security configuration(ssl config) passwords at broker and clien...

英文: Reactive Kafka and many partitions 问题 Kafka分区的数量对于Reactive Kafka接收器是否重要，或者效率是否与一个Kafka分区相同（因为响应式...

英文: How to set ID header in Spring Integration Kafka Message? 问题 我有一个演示的Spring Integration项目，它接收Kafk...

英文: Why am I getting an older timestamp than specified when using KafkaConsumer.offsetsForTimes() in...

英文: Custom Kafka Deserializer ignores null messages 问题 我正在使用Kotlin Spring Boot，并且我有一个自定义的Kafka反序列化器。...