ApacheKafkaSRMSG18304:未知的通道
创始人
2024-09-06 04:30:41
0

此错误通常意味着在使用Kafka Producer API发送消息时,指定了不正确的或不存在的通道名称。解决此问题需要检查代码中指定通道名称的部分,并确保通道名称正确。以下是一个示例,展示如何在Kafka Producer的代码中指定通道名称:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
Producer producer = new KafkaProducer<>(props);

String topicName = "my-topic";
String message = "Hello Kafka!";
ProducerRecord record = new ProducerRecord<>(topicName, message);
producer.send(record);

在此示例中,我们通过在ProducerRecord构造函数中指定topicName指定通道名称。如果通道名称不存在,则会出现SRMSG18304错误。因此,确保使用正确的通道名称。

相关内容

热门资讯

玩家攻略推荐!微乐云南小程序辅... 玩家攻略推荐!微乐云南小程序辅助器,wejoker辅助机器人,扑克教程(有挂技巧)是一款可以让一直输...
科技揭秘!九酷众娱辅助,微信小... 科技揭秘!九酷众娱辅助,微信小程序微乐辅助器脚本(竟然是真的有挂)1、每一步都需要思考,不同水平的挑...
最新通报!九九联盟解码器,we... 最新通报!九九联盟解码器,wepoker辅助插件功能,曝光教程(有挂秘诀);最新通报!九九联盟解码器...
分享开挂内幕!广东雀神挂件定制... 分享开挂内幕!广东雀神挂件定制,蜀山四川智能辅助插件下载(好像真的是有挂)1、下载好蜀山四川智能辅助...
避坑细节!途游四川辅助器是真的... 避坑细节!途游四川辅助器是真的吗,wepoker有没有挂,黑科技教程(有挂透明挂);1.途游四川辅助...
分享开挂内幕!微乐小程序礼包码... 分享开挂内幕!微乐小程序礼包码,八张透视辅助(总是真的有挂)1、完成微乐小程序礼包码辅助器v3.3的...
推荐十款!湖南牵手胡子跑辅助,... 推荐十款!湖南牵手胡子跑辅助,德州透视竞技联盟,新2025版(有挂解密);致您一封信;亲爱湖南牵手胡...
2024教程!518互游辅助器... 2024教程!518互游辅助器下载,四川微乐微信麻将小程序辅助(好像真的有挂)暗藏猫腻,小编详细说明...
分享一款!长城互娱辅助,德普之... 分享一款!长城互娱辅助,德普之星透视辅助软件,黑科技教程(有挂透视)是一款可以让一直输的玩家,快速成...
最新技巧!美猴王房卡辅助,微乐... 最新技巧!美猴王房卡辅助,微乐小程序多乐辅助器(切实是有挂)1、起透看视 微乐小程序多乐辅助器辅助软...