从Kafka消费数据

Question

我正在通过为以下三个属性指定类来使用来自Kafka Topic的消息：--property key.deserializer = org.apache.kakfa.common.serialization.StringDesrializer-属性value.deserializer = org.apache.kafka.common.serialization.LongDesrializer

但是我收到以下错误：

Exception in thread "main" java.lang.ClassNotFoundException:
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:264)
        at kafka.tools.DefaultMessageFormatter.init(ConsoleConsumer.scala:477)
        at kafka.tools.ConsoleConsumer$ConsumerConfig.<init>(ConsoleConsumer.scala:312)
        at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:51)
        at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)

任何人都可以提出建议，我该如何解决？

Answer 1

找不到这些类，因为两个De序列化器类都不是Serializer接口的一部分，并且仅在Deserializer中可用。

使用以下选项可以解决问题：

--property key.deserializer = org.apache.kakfa.common.deserialization.StringDesrializer --property value.deserializer = org.apache.kafka.common.deserialization.LongDesrializer