英文: AKHQ: Couldn't find any clusters on your configuration file, please ensure that the configur...
我的Spring Kafka单元测试几乎每次都遇到了ProducerFencedException。
英文: Why my Spring Kafka unit test almost ran into ProducerFencedException every time 问题 测试包括两个测试案例 @...
How can I consume data from specific partitions in Kafka using Confluent Python?
英文: How can I consume data from specific partitions in Kafka using Confluent Python? 问题 我尝试了这段代码,但它也...
transaction-id-prefix需要在Spring Kafka 3中的同一应用程序实例中保持相同吗?
英文: transaction-id-prefix need to be identical for same application instance in spring kafka 3? 问题 在...
org.apache.kafka.common.KafkaException: 构建 Kafka 生产者失败
英文: org.apache.kafka.common.KafkaException: Failed to construct kafka producer 问题 我有一个docker-compose...
将Dataset<Row>转换为要添加到Kafka的键和值。
英文: Spark: Convert a Dataset<Row> to key and value to be added in Kafka 问题 我正在尝试将Spark连接到具有位置数...
Kafka的磁盘使用量为什么每7天会周期性下降?
英文: Why would Kafka's disk usage cyclically drop every 7 days? 问题 这种模式在另一个集群上看不到,该集群的保留设置(默认)也为7...
Kafka Consumer – How can I do Replay/Get the same message from kafka broker in case my service is down/some exception occurred
英文: Kafka Consumer - How can I do Replay/Get the same message from kafka broker in case my service i...
Kafka在使用Docker时无法在9092端口启动。
英文: Kafka does not start on port 9092 using docker 问题 我按照这个链接 使用Docker启动Kafka。在我的操作系统中,Docker和Docker...
我可以将Kafka Stream的输出发送到REST API端点吗?
英文: Can I send output of a Kafka Stream to a REST API endpoint 问题 我目前有一个应用程序,它使用Consumer API从Kafka主题...
41