我正在使用Mirth (HL7v2消息)和Apache Kafka。 是否可以创建一个带有TCP Sender目标的通道，以便为apache kafka中的主题发送消息？下图显示了可填充的字段 ?
浏览 18提问于2021-03-24得票数 0
为什么kafka 0.10控制台生产者不能向kafka 0.9发送消息？
我在0.9版本中启动了kafka控制台消费者(在服务器端)。我正在启动0.10版本的kafka控制台生产者(在客户端)。为什么新的生产者不能向旧的消费者发送消息？是否可以将新的生产者设置为一种弃用模式，以便向旧的
浏览 11提问于2016-08-30得票数 0
回答已采纳
我正在使用星火应用程序中的Kafka向某个主题发送一些通知。我在我的Spark日志中看到了大量以下异常，并且消息没有传递到主题。15/09/08 03:29:24错误发件人: kafka生产者I/O线程中的未明错误： at org.apache.kafka<
浏览 7提问于2015-09-08得票数 1
回答已采纳
我可以在kafka中使用线程向单个主题发送消息吗？我开发了一个kafka生产者在春季启动发送消息到一个kafka主题，我需要知道是否有可能创建多个线程发送多个消息到一个主题。例如:在一个生产者中创建三个线程，同时将三个不同的消息从每个线程发送到单个k
浏览 1提问于2019-04-04得票数 2
1回答
如何处理卡夫卡中的大消息，比如超过20 to的消息等等。2009-03- 13 08:59:10,923错误当发送消息到主题测试时，键:13字节，值: 11947696字节与错误：(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.Reco
浏览 0提问于2019-03-13得票数 1
回答已采纳
1回答
我们希望使用exactly-once语义将数据存储在Kafka中，以避免消息重复。具有以下属性的生成器： spring.kafka.producer.properties.acks=all
浏览 86提问于2021-07-27得票数 1
回答已采纳
我已经在我的Windows10笔记本电脑上在WindowsLinux3.4.12下安装了Kafka1.1.0和ZooKeep3.4.12。我可以在ubuntu中获取和使用消息，但是当我想从windows (使用java程序或使用kafka-console-Producer.bat工具)生成消息时，我有以下错误：
2018-05-11 15:31:01,449在用键向主题测试发送消息时出错: null
浏览 0提问于2018-05-11得票数 0
我们拥有的Kafka代理的版本是1.0.1。当我们通过创建reactor.kafka.sender.SenderRecord间歇性地向Kafka发送消息时，在响应Kafka时，当查找reactor.kafka.sender.SenderResult.exception()时，我们有 异常中填充的java.lang.RuntimeException: org.<em
浏览 154提问于2019-02-13得票数 1
回答已采纳
有一个生产者和两个消费者为这一主题。我需要做的是过滤由生产者产生的消息，根据它们的前缀。例如，如果消息以'a‘前缀开头，那么只有第一个使用者必须接受它。我做了很多搜索，我发现的是过滤来自一个主题的消息，然后在过滤后将它们发送到不同的主题。但如前所述，我需要对一个主题进行过滤。我怎么能在卡夫卡做到这一点？
浏览 1提问于2018-03-01得票数 4
回答已采纳
我已经在我的centos服务器上安装了Apache。我只是想把一条消息写到另一台服务器上的一个主题上。/kafka-console-producer.sh --broker-list xxx.yyy.com:2181 --topic topicx
向主题cds_organization发送消息时出现错误:
浏览 1提问于2019-04-23得票数 0
回答已采纳
kafka-控制台-生产者-代理-列表本地主机:9092-主题com-hftl2 < file.txt
向主题com-hftl2发送消息时出错(键为: null，值: 20299831字节带有错误：(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka.common.errors.RecordTooL
浏览 1提问于2019-12-25得票数 0
通过kafka-console-producer.bat发送到localhost时不创建消息，错误消息为：
向主题测试发送消息时出错，key: null，值:2字节，错误: 60000 ms后，元数据中不存在(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) org.apache.kafka<
浏览 1提问于2019-09-12得票数 0
1回答
我在活动上用“kafka -node”创建了kafka消费者。consumer.on('message' ()=>{}) ) throw e })这是从卡夫卡消费者那里向mongodb发送</em
浏览 0提问于2019-04-03得票数 0
回答已采纳
向apache发布消息列表。有人可以使用kafka提供示例代码，说明如何识别哪些消息成功地发布到主题中，哪些消息由于响应失败而失败？(请注意，我在一个请求中作为一个批处理发送消息列表。)
浏览 0提问于2019-08-12得票数 4
1回答
正如我所看到的，Kafka模板内部使用了Kafka生成器。我只想知道到底有什么不同。此外，我发现与Kafka producer相比，Kafka模板中提供了许多send()方法。
请帮我拿一下。
浏览 1提问于2020-09-09得票数 1
我们有多个节点的spring-boot app，并使用KafkaTemplate生成kafka消息。在类路径中，我们同时拥有org.springframework.kafka:spring-kafka和io.micrometer:micrometer-core。在我们的例子中，消息是连续产生的，每个主题(具有多个分区的主题)每秒大约产生几千条消息
浏览 47提问于2020-07-01得票数 1
回答已采纳
我已经安装了kafka并将用户和密码定义为SASL_PLAINTEXT协议，我在控制台中创建了一些示例，我可以向主题发送消息并使用它们各自的凭据接收这些消息，现在我需要在我的spring boot应用程序中复制该配置这是我的application.yml文件： server:spring: bootstrap-servers:
浏览 144提问于2019-01-08得票数 1
回答已采纳
我们在2台服务器上以分布式模式运行kafka。我通过Java向具有复制因子2和1分区的队列发送消息给Kafka。 props.put("value.serializer", "org.apache.kafka.common.serializa
浏览 5提问于2017-08-17得票数 10
我正在尝试开发一个基于IoT的应用程序，其中多个设备将生成数据并将其发送到Kafka broker。这些设备的数量可能在6万到7万左右。可以有5-10种不同的设备类型，但是，每种类型的设备数量将以千为单位，例如每个设备数量为20-4万。提前谢谢你，
阿维纳什·德什穆
浏览 5提问于2019-04-04得票数 3
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
