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());
... View more
