属性 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");
生产者.发送(数据);
我正在尝试执行此代码,然后在线程“main”java.lang.NoSuchMethodError 中出现异常:scala.Tuple2._1$mcI$sp()I 这个异常。我添加了所有与 scala 相关的 jar file.plese suggedt me ??????