用于与Apache Kafka生产者API相关的问题。有关制作Kafka主题的任何问题。生产者失败和恢复，幂等性和事务性API。
KafkaTemplate是否在Spring引导线程中是安全的。我可以创建一个KafkaTemplate并使用它将信息发送到我的Web服务中的多个请求的相同kafka主题。
我在侦听器方法中的Consumer类InventoryEventReceiver中收到以下错误。不确定出现NullPointerException的原因。我只是POST两个InventoryEvent对象....
我有以下代码：类型Request = EitherT [IO，Throwable，KkProducerRecordMetadata] def create（producer：=> KkProducerCreator）：IO [Producer [String，String]] = IO {try {...
我正在运行Kafka集群。示例代码：属性props = new Properties（）; props.put（ProducerConfig.BOOTSTRAP_SERVERS_CONFIG，“localhost：9092，localhost：...
如何控制Kafka Producer或Consumer的控制台日志记录级别？我在Scala中使用Kafka 0.9 API。每次调用KafkaProducer发送时，控制台都会输出如...
我是kafka的新手，我正试图通过http从外部应用程序发布数据，但我找不到这样做的方法。我已经在kafka中创建了一个主题并测试它生成和使用...
KafkaConsumer和KafkaProducer空闲时间配置
我们的应用程序长期运行，需要运行直到停止/杀死。其配置是为Producer和Consumer设置connections.max.idle.ms，类型为long。有办法......
我有一个简单的Producer-Consumer设置：1个生产者（作为一个线程）和2个消费者（作为2个进程）。生产者的run方法：def run（self）：producer = KafkaProducer（bootstrap_servers = ...
我们在我们的应用程序中使用kafka，我们发送了太多的消息，每条消息的大小都很小，我的意思是消息大小不是问题，如果你试图发布太多很多就是他们的问题...
我是Kafka的新手，但是看过一些教程，所以我知道Kafka是如何工作的。我正在尝试运行一个我用Python编写的生产者但我不知道如何在我启动后运行此文件...
当在代理配置中将log.segment.bytes设置为512兆字节时，我有一个kafka主题不断滚动新的日志段。大多数日志文件平均为5-10千字节。如果我看......
我是卡夫卡的新人。我的要求是，我有两个分区，例如Partition-0和Partition-1，我有一个值列表，它们也包含KEY值。我想根据我的密钥存储数据......
我打算为Kafka Producer编写自己的Partitioner，所以我看到了Kafka的DefaultPartitioner的实现。我看到它调用了Cluster的availablePartitionsForTopic，有时......
我已经限制了一个主题的一个分区用于特定服务（因此所有请求都将在此处到达服务X）。对于任何其他服务请求将到达剩余的N个分区。 ...
我们正在使用kafka 0.10.2.1。文档指定缓冲区即使没有填充也可以发送 - 默认情况下，即使有其他缓冲区，也可以立即发送缓冲区...
AIX 7.1 crontab中的Kafka Producer收到JAVA错误：错误的主要版本
我在深入研究这个错误时遇到了一些困难，似乎无法通过我的设置找到与此问题相关的任何内容。我确实找到了一些关于错误的文章但是......
在我的应用程序中，我将使用来自100多个主题的数据。我应该为每个主题创建一个消费者还是从所有主题中创建一个消费者消费者？将创造100个消费者创造100 ...