Comment envoyer des données JSON à Kafka en utilisant Java

Question

Sur Internet, je ne vois que quelques nouvelles sur Java produisant le type STRING.
Selon la classe producteur de Java, vous pouvez personnaliser le type de message envoyé, tel que producteur.send(new KeyedMessage<String, HashMap<String, String>>(topic, message);
Cependant, si vous exécutez de cette façon, une erreur sera signalée. Comme suit, veuillez donner une réponse d'expert :
Exception dans le fil "Thread-4" java.lang.ClassCastException : java.util.HashMap ne peut pas être converti en java.lang.String

at kafka.serializer.StringEncoder.toBytes(Encoder.scala:46)
at kafka.producer.async.DefaultEventHandler$$anonfun$serialize.apply(DefaultEventHandler.scala:130)
at kafka.producer.async.DefaultEventHandler$$anonfun$serialize.apply(DefaultEventHandler.scala:125)
at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
at kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:125)
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:52)
at kafka.producer.Producer.send(Producer.scala:77)
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
at com.Model.Producer.kafkaProducer.run(kafkaProducer.java:35)

Answer 1

Document, sérialisez-le simplement dans String