java - 尝试使用 kafka-client 2.6 时出错
问题描述
我正在学习 Kafka,当我尝试实现一个只会发送“Hello World”的简单生产者时
package com.github.joe.kafka.tutorial1;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
import java.util.Properties;
public class ProducerDemo {
public static void main(String[] args) {
Properties properties = new Properties();
String bootstrapServers = "127.0.0.1:9092";
String topic = "first_topic";
properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,bootstrapServers);
properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
KafkaProducer<String,String> producer = new KafkaProducer<String, String>(properties);
ProducerRecord<String,String> record = new ProducerRecord<String, String>(topic,"Hello World");
producer.send(record);
producer.flush();
producer.close();
}
}
问题是当我使用 kafka-client v2.0.0 时它可以工作,但是当我使用 kafka-client 2.6.0 时它失败并且我收到以下错误:
[kafka-producer-network-thread | producer-1] ERROR org.apache.kafka.common.utils.KafkaThread - Uncaught exception in thread 'kafka-producer-network-thread | producer-1':
java.lang.NoClassDefFoundError: com/fasterxml/jackson/databind/JsonNode
at org.apache.kafka.common.requests.ApiVersionsRequest$Builder.<clinit>(ApiVersionsRequest.java:36)
at org.apache.kafka.clients.NetworkClient.handleConnections(NetworkClient.java:910)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:555)
at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:325)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:240)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: com.fasterxml.jackson.databind.JsonNode
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:352)
at java.lang.ClassLoader.loadClass(ClassLoader.java:351)
... 6 more
[main] INFO org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
解决方案
上述建议对我有用。我添加了解决问题的以下依赖项。
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.8</version>
</dependency>
推荐阅读
- php - 如何在 PHP 中将多个本地数据库中的数据同步和合并到实时服务器数据库?
- python - 使用带有自定义参数的 subprocess.Popen 时 Python 出错
- flutter - 如果颤动中没有指定颜色,标签文本和前缀图标采用什么颜色(默认颜色)?
- openssl - OPENSSL 创建根 CA 签名证书
- unit-testing - 如何在 Jasmine 中使用回调和返回类型模拟函数
- mongodb - mongoDB 通过 id 查找并返回匹配的子文档
- python - Pyspark:读取多个 csv 文件并用源注释它们
- javascript - JS:我如何使这个脚本更小。随机对象
- python - 如何在 python 中使用不同模式在谷歌大查询中附加数据框?
- python - 使用 SMTP 使用 python 将多个附件从 gmail 发送到 gmail?