kafka 0.8.2.0 的默认序列化程序
Default serializer for kafka 0.8.2.0
我正在使用他们的新 KafkaProducer API 设置 Kafka 生产者并收到以下错误
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)
http://kafka.apache.org/documentation.html#newproducerconfigs 似乎没有默认的序列化程序和文档,我看不到可能的值。
此题针对Kafka 0.8.2.0版本
假设您想要一个 StringSerializer,请使用:
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
完整示例在这里:https://github.com/CameronGregory/kafka/blob/master/TestProducer.java
Kafka 的早期版本带有默认的序列化程序,但这造成了很多混乱。
对于 0.8.2,您需要自己从 API 附带的 StringSerializer 或 ByteArraySerializer 中选择一个序列化程序,或者构建您自己的序列化程序。
API 序列化程序可以在
字符串序列化器:
http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/StringSerializer.html
字节数组序列化器:
http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html
因此,如果您希望使用默认的序列化程序,您的解决方案是使用以下选项之一。
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
或
props.put("key.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");
我正在使用他们的新 KafkaProducer API 设置 Kafka 生产者并收到以下错误
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)
http://kafka.apache.org/documentation.html#newproducerconfigs 似乎没有默认的序列化程序和文档,我看不到可能的值。
此题针对Kafka 0.8.2.0版本
假设您想要一个 StringSerializer,请使用:
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName()); props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
完整示例在这里:https://github.com/CameronGregory/kafka/blob/master/TestProducer.java
Kafka 的早期版本带有默认的序列化程序,但这造成了很多混乱。
对于 0.8.2,您需要自己从 API 附带的 StringSerializer 或 ByteArraySerializer 中选择一个序列化程序,或者构建您自己的序列化程序。
API 序列化程序可以在 字符串序列化器: http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/StringSerializer.html 字节数组序列化器: http://kafka.apache.org/082/javadoc/org/apache/kafka/common/serialization/ByteArraySerializer.html
因此,如果您希望使用默认的序列化程序,您的解决方案是使用以下选项之一。
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
或
props.put("key.serializer", "org.apache.kafka.common.serialization.ByteArraySerializer");