我遵循youtube上的指南，使用c为kafka创建一个消费者应用程序，但是在使用部分，我不能使用confluent.kafka.serialization。缺少序列化。关于我应该包括/使用什么来使用stringdeserializer有什么想法吗？
mklgxw1f1#
我相信你下面的教程使用的是旧的confluent.kafka库，它已经过时了。如果要设置反序列化程序，可以使用接受ideserializer接口的setvaluedeserializer和setkeydeserializer方法。您可以实现自己的反序列化程序，它可以在内部使用stringdeserializer。您还可以查看另一个答案，它提供了一个简单的ideserializer实现。
1条答案
按热度按时间mklgxw1f1#
我相信你下面的教程使用的是旧的confluent.kafka库，它已经过时了。
如果要设置反序列化程序，可以使用接受ideserializer接口的setvaluedeserializer和setkeydeserializer方法。您可以实现自己的反序列化程序，它可以在内部使用stringdeserializer。
您还可以查看另一个答案，它提供了一个简单的ideserializer实现。