用于与Apache Kafka生产者API相关的问题。有关制作Kafka主题的任何问题。生产者失败和恢复，幂等性和事务性API。
Confluent Python Avro Producer：数据{'..'}不是该模式的示例
我无法为特定架构生成数据，也无法理解原因。通过使用合流的“ avro-random -...
阅读有关主题分区中消息排序的本文：https://blog.softwaremill.com/does-kafka-really-guarantee-the-order-of-messages-3ca849fd19d2允许重试而未设置最大值。
包kafka.producer更改为kafka_2.11后不存在
我已将pom文件中的Kafka版本从2.10更改为2.11，现在我从 org.apache.kafka 了解pom中的错误更改。
如何在同一主题上使用globalKtable和StateStore？
只是为了澄清，我是Kafka的新手，很抱歉，如果我的问题似乎没有记载，我正在阅读教程，文档以及我能理解的一切。我正在尝试从GlobalStore中读取所有值...
为了使用大数据技术应用实时语音分析，我试图在一开始使用KAFKA。因此，首先我使用WAVIO API将.wav文件转换为字节，然后发送消息...
Kafka和数据库调用之间的Spring @Transactional问题
我正在尝试检查Kafka和数据库调用（Postgres）之间的事务状态，如果数据库调用失败，则Kafka不应将该特定消息发送到Kafka主题上。我是...
我们使用的是3个节点的Kafka群集，共有151个主题，每个主题都有1个分区。并且我们已经配置了复制因子= 3。当我们启动kafka经纪人时，出现以下错误：...
我如何立即在kafka和kafka-streams中获得所产生事件的结果？
我在以下情况下简化了我的问题：3个朋友共享一张会员卡。该卡有两个限制，最多可以使用10次（无论使用哪个卡，即friend_a都可以...
我如何在kafka和kafka-streams中获得所产生事件的结果？
我在以下情况下简化了我的问题：3个朋友共享一张会员卡。该卡有两个限制，最多可以使用10次（无论使用哪个卡，即friend_a都可以...
Spring Cloud Stream和Kafka：Kafka Producer序列化错误
我是Spring Cloud Stream和Kafka的新手。在有效负载中发送字符串时，我从kafka生产者收到以下错误。任何帮助或见解将不胜感激。我尝试过...
如何通过CLI /命 令行使用用户名和密码保护kafka主题？
我已经在Windows 10上安装了Docker，还安装了Kafka。我在Kafka集群中创建了一个“测试”主题。现在，我想使用简单的用户名和密码来保护主题。我是超级...
下面是我向kafka发布消息的代码。我需要知道在以下情况下会发生什么，当消息被异步发送并且没有得到所有relicas的确认时，它是否在客户端抛出异常？...
[发送到Kafka主题时获取某些消息的TimeoutException
Exception Stacktrace：org.springframework.kafka.core.KafkaProducerException：发送失败；嵌套的异常是org.apache.kafka.common.errors.TimeoutException：由于****-656，到期1条记录...
如何有效地从Seq [String]发送消息到Kafka主题
在我的Scala（2.11）流应用程序中，我正在使用IBM MQ中一个队列中的数据，并将其写入具有一个分区的Kafka主题。从MQ消耗数据后，消息有效负载就会得到...
Python，Kafka和Docker-KafkaConsumer一直挂着
我有以下docker-compose文件：版本：'3.1'服务：postgres_db：图像：postgres重新启动：始终环境：POSTGRES_USER：admin ...
我们在我们的项目中拥有微服务架构。有一个微服务，其中调度程序触发向Kafka发送消息的逻辑。问题是，如果有多个微服务...
Kafka：如何连接kafka-console-consumer以获取远程代理主题内容？
我在ec2上的一台机器上安装了kafka zookeeper和3个代理，端口为9092..9094，并尝试从另一台机器上使用主题内容。端口2181（zk），9092、9093和9094（...] >>
用于Apache Kafka的Spring：无法识别的生产者配置-'delivery.timeout.ms'
我有一个Spring Boot应用程序，带有用于Apache Kafka的Spring，用于将消息发送到kafka集群上的主题。我已经自动为delivery.timeout.ms和应用程序连接了属性...
我正在使用kafka-node模块将消息发送到kafka。在一个集群环境中，我的主题有3个分区，复制因子为3。主题描述为-Topic：clusterTopic ...