英文: How to make spark streaming commit in each batch when limiting Kafka batch size? 问题 为了在使用Spark流处...
Kafka会在一段时间后停止运行,出现丢失的代理。
英文: Kafka stops after a certain period of time, lost brokers 问题 我有 4 个正在运行 Debezium 的 Kafka 实例。在正常运行...
Kafka生产者在Eclipse中未将消息发送到主题。
英文: Kafka Producer in eclipse does not send messages to topic 问题 以下是翻译好的内容: 无法使用Java从Eclipse(在Window...
JSON在Kafka中未被格式化。
英文: JSON Not getting formatted in Kafka 问题 我正在将Java对象序列化为JSON,如下所示: ObjectMapper mapper = new Object...
如何在Java Kafka应用程序客户端中判断是否达到了max.poll.interval.ms?
英文: How to know if max.poll.interval.ms is reached in java kafka application client? 问题 在 Kafka 达到 m...
将偏移量提交给Kafka在多次尝试处理失败后,使用reactor-kafka。
英文: Commit offset to Kafka in reactor-kafka after a few attempts to process have failed 问题 有一个 Kafka...
无法在Kafka Connect 2.4中成功覆盖我的连接器。
英文: Can't override successfully in Kafka Connect 2.4 my connectors 问题 你好,我正在寻找如何通过Java代码使用已在2.3版...
Axon配置 – 在@eventhandlers抛出异常后的Kafka重试策略
英文: Axon Config - Kafka retry policies after @eventhandlers thrown exception 问题 我已经开始在我的项目中使用Axon 4....
Spark with kafka: NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/util/Collection;)
英文: Spark with kafka: NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(L...
Java Kafka客户端记录每个线程的所有配置。
英文: Java kafka client logging all the config for each thread 问题 我有一个Java客户端(使用kafka客户端版本2.4.1),连接到一个...
41