【发布时间】:2026-02-16 15:35:01
【问题描述】:
属性 props = new Properties();
props.put("zk.connect", "localhost:2181");
props.put("serializer.class", "kafka.serializer.StringEncoder");
ProducerConfig config = new ProducerConfig(props);
生产者生产者=新生产者(配置);
ProducerData data = new ProducerData("test-topic", "test-message");
producer.send(数据);
我正在尝试执行此代码,然后在线程“main”java.lang.NoSuchMethodError 中出现异常:scala.Tuple2._1$mcI$sp()I 这个异常。 我添加了所有 scala 相关的 jar 文件。请建议我??????
【问题讨论】:
标签: producer