英文: create a map using key value of ConsumerRecord kafka 问题 以下是您要翻译的部分: 我正在使用KafkaConsumer从一系列Kafka主...
为什么我的Kafka消费者在我寻求到另一个位置时会得到一个ValueError?
英文: 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
英文: golang undefined module, which is downloaded correctly 问题 我按照kafka go示例项目上的说明进行操作。在使用以下命令获取模块后: ...
Kafka代理可以通过多个端口进行连接吗?
英文: Can Kafka brokers connect through more than one port 问题 我们有很多微服务连接到一个 Kafka 代理集群,作为企业消息总线。 在我们的可...
如何检查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 client side
英文: Is there a way to encrypt kafka security configuration(ssl config) passwords at broker and clien...
Reactive Kafka 和多个分区
英文: Reactive Kafka and many partitions 问题 Kafka分区的数量对于Reactive Kafka接收器是否重要,或者效率是否与一个Kafka分区相同(因为响应式...
如何在Spring Integration Kafka消息中设置ID标头?
英文: 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 Java?
英文: Why am I getting an older timestamp than specified when using KafkaConsumer.offsetsForTimes() in...
自定义的Kafka反序列化器忽略了空消息。
英文: Custom Kafka Deserializer ignores null messages 问题 我正在使用Kotlin Spring Boot,并且我有一个自定义的Kafka反序列化器。...
41