kafka自定义消息?报错

props.put("serializer.class"," kafka.serializer.StringEncoder");

serializer.class要用kafka包中的,不是你自己写的，不知道你是一定要自己实现序列化的类还是只是要发数据，只是发数据的化用 kafka.serializer.StringEncoder吧

回复 @卢禹:如果把消息定义成json格式，请问下具体怎么发送json格式的消息回复 @卢禹:他的文章是13年的那时候是kafka0.7现在的api已经变了.所以那个例子应该是不太行了，如果一定要那么实现建议你找找官方文档或者最近的例子回复 @Small雀:应该是kafka的版本的问题，kafka每个版本变化较大，我一般不这么实现自定义消息。个人建议用json格式，不需要自己实现serializer。你说的那个文章我大概看了下他用“-”分隔的数据，个人觉得不是特别合适，另外如果一定要实现，也不一定要在那层实现，可以在之前就把对象变成字符串来发送。如果不是极端考虑效率问题的化例子中可以使用ProducerData这个类型，而我不知道为什么无法使用这个类型，所以就用了KeyedMessage代替。StringEncoder只能实现发送String型的数据，我想发送我自定义的数据，例子地址是http://my.oschina.net/ielts0909/blog/100645?fromerr=6xU38Goj

引用来自“卢禹”的评论

props.put("serializer.class"," kafka.serializer.StringEncoder");

serializer.class要用kafka包中的,不是你自己写的，不知道你是一定要自己实现序列化的类还是只是要发数据，只是发数据的化用 kafka.serializer.StringEncoder吧

谢谢，我再继续尝试