Created 01-16-2018 02:13 PM
2018-01-12 15:12:30.429 o.a.k.c.p.ProducerConfig [WARN] The configuration 'key.deserializer' was supplied but isn't a known config.
2018-01-12 15:12:30.429 o.a.k.c.p.ProducerConfig [WARN] The configuration 'value.deserializer' was supplied but isn't a known config.
2018-01-12 15:12:30.429 o.a.k.c.p.ProducerConfig [WARN] The configuration 'sasl.jaas.config' was supplied but isn't a known config.
2018-01-12 15:12:30.430 o.a.k.c.p.ProducerConfig [WARN] The configuration 'serializer.class' was supplied but isn't a known config.
kafkaProperties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
kafkaProperties.put("value.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
kafkaProperties.put("serializer.class", DefaultEncoder.class.getName());
Created 01-16-2018 11:57 PM
Looks like you are using the consumer properties in producer and hence kafka is ignoring.
Refer : https://kafka.apache.org/0100/documentation.html for all valid configs for the version you are using.
Created 01-16-2018 11:57 PM
Looks like you are using the consumer properties in producer and hence kafka is ignoring.
Refer : https://kafka.apache.org/0100/documentation.html for all valid configs for the version you are using.