学习kafka-producer-api－开发者之家

问题描述在我的SpringBootKafka发布应用程序中，我希望提供对以字符串(Json)或字节格式发布消息的支持，因为我希望同时支持json和avro。但是春装中的卡夫卡模板让我们只能定义其中的一个模板。有没有办法同时使用两个模板或任何其他方式来同时支持JSON和Avro？K

问题描述我正在尝试用ApacheKafka替换兔子MQ，在规划时，我遇到了几个概念性规划问题。首先，我们对每用户队列策略使用RabbMQ，这意味着每个用户使用一个队列。这符合我们的需要，因为每个用户代表要与该特定用户一起完成的一些工作，并且如果该用户导致问题，则队列对于其他用户永

问题描述我正尝试在批量模式下使用具有以下属性的KafkaConnectJDBC源连接器。connector.class=io.confluent.connect.jdbc.JdbcSourceConnectortimestamp.column.name=timestampconn

问题描述我有一个REST终结点，可以由多个用户同时调用。该REST终结点调用事务性Kafka生成器。我的理解是，如果我们使用Transaction，我不能同时使用同一个KafkaProducer实例。如何高效地为每个HTTP请求创建新的KafkaProducer实例？//Kafk

问题描述我正在使用Kafka_2.11-2.1.1以及使用Spring2.1.0.RELEASE的制片人。我在向Kafka主题发送消息时使用了Spring，我的制作人生成了很多TimeoutExceptionsorg.apache.kafka.common.errors.Time

问题描述我在UbuntuWSL2上成功运行了最新的Kafka。我可以在我在WSL上运行的Ubuntu中启动ZooKeeper、Kafka服务器、创建主题、控制台生产和控制台消费。但是，当我进入Windows上的IntelliJ并创建一个简单的Java生成器时，它似乎无法连接到代理

问题描述我正在使用apachecamelkafka作为客户端来生成消息，我观察到kafka生产者需要1毫秒来推送消息，如果我使用骆驼聚合将消息合并到批处理中，那么推送单个消息需要100毫秒.Iamusingapachecamelkafkaasclientforproducingm

问题描述我对kafka相当陌生，所以如果这个问题微不足道，请原谅我.为了计时测试，我有一个非常简单的设置，如下所示:Iamfairlynewtokafkasoforgivemeifthisquestionistrivial.Ihaveaverysimplesetupforpurp

问题描述我有以下kafka制作人Api程序，我是kafka本身的新手.下面的代码从API之一获取数据并将消息发送到kafka主题.IhavebelowkafkaproducerApiprogramandiamnewtokafkaitself.Belowcodefetchdataf

问题描述我有一个由3个Kafka代理组成的集群，所有主题的复制因子为3.由于最近几天我面临这个问题，突然(一天几次)消费者和生产者在得到响应时卡住了，即使Kafka在所有3个服务器上运行，直到我检查代理日志(连接到0已断开连接在响应被读取之前")并找出罪魁祸首节点为0(在本例中为