プロパティ props = new Properties();
props.put("zk.connect", "localhost:2181");
props.put("serializer.class", "kafka.serializer.StringEncoder");
ProducerConfig config = 新しい ProducerConfig(props);
プロデューサー プロデューサー = 新しいプロデューサー (構成);
ProducerData data = new ProducerData("テスト トピック", "テスト メッセージ");
プロデューサー.送信(データ);
このコードを実行しようとすると、スレッド「メイン」で例外が発生しました java.lang.NoSuchMethodError: scala.Tuple2._1$mcI$sp()I この例外。scala 関連のすべての jar ファイルを追加しました。