Standard Serializer für kafka 0.8.2.0

Question

Ich Einrichtung Kafka Hersteller ihre neuen KafkaProducer API und folgende Fehler bekommen

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Missing required configuration "key.serializer" which has no default value. 
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:124) 
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:48) 
at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:235) 
at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:129) 
at com.kafka.producer.App.KafkaProducer(App.java:43) 
at com.kafka.producer.App.main(App.java:33) 
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
at java.lang.reflect.Method.invoke(Method.java:483) 
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134) 

Es scheint http://kafka.apache.org/documentation.html#newproducerconfigs kein Standard Serializer und die Dokumentation zu sein, und ich sehe nicht möglich Werte.

Diese Frage ist für Kafka Version 0.8.2.0

Answer 1

Die früheren Versionen von Kafka kam mit Standard Serialisierer, aber das verursachte viel Verwirrung.

Mit 0.8.2, müssten Sie einen Serializer selbst aus StringSerializer oder ByteArraySerializer, die mit API kommt oder wählen Sie selbst erstellen. http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/StringSerializer.html ByteArraySerializer: http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html

So würde Ihre Lösung sein, eine der folgenden Optionen zu verwenden, wenn Sie Standard-Serializer verwenden suchen

Die API Serializer können StringSerializer finden.

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); 

oder

props.put("key.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer"); 

Answer 2

Unter der Annahme, dass Sie eine StringSerializer, verwenden wollen:

 
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName()); 
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName()); 

vollständiges Beispiel hier: https://github.com/CameronGregory/kafka/blob/master/TestProducer.java