apache-kafka

英文: Call Controller from kafka component 问题 I've been searching a lot about it, and the only two thi...

英文: How does default kafkaListenerContainerFactory work 问题 我有一个Kafka消费者的Java应用程序。 我从该应用程序中读取两个不同的Kaf...

英文: Mockito Unit Tests stubbing a method throws NullPointerException 问题 我正在为下面的类中的 run() 方法编写一些单元测试：...

英文: Kafka consumer showing numbers in unreadable format 问题 以下是您提供的内容的翻译： 我正在尝试使用Kafka流处理。我正在从一个主题中读取...

英文: SSL with default KafkaConsumer 问题 默认的 KafkaConsumer 实例是否支持使用 SSL 进行消费？我会认为不支持，但我目前还没有找到关于将使用哪些默认...

英文: Why kakfa topic partition is not receiving messages? 问题 我有一个包含3个代理（brokers）和一个包含8个分区（partitions）...

英文: Kafka Streams API: Session Window incompatible types 问题 我有以下代码片段： groupedStream.windowedBy(Sessi...

英文: What happens in Kafka if you create a new partition for a topic? 问题 我在一些在线指南上看到，如果你正在使用键排序，新分区最终...

英文: Reading Message from Kafka Topic and Dump it into HDFS 问题 我试图从Kafka主题消费数据，将其加载到数据集中，然后在加载到HDFS之前...

英文: How to list all available brokers in Kafka cluster using Java API? 问题 仅翻译内容如下： 标题所述。 是否有任何方式（使用K...