Hi all; I'm getting above exception when i try to produce simple string messages using kafka 0.9.01 version. I could not produce messages now.
The warning i get is; buffer.memory = 33554432 timeout.ms = 30000 key.serializer = class org.apache.kafka.common.serialization.StringSerializer sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 ssl.keystore.type = JKS ssl.trustmanager.algorithm = PKIX block.on.buffer.full = false ssl.key.password = null max.block.ms = 60000 sasl.kerberos.min.time.before.relogin = 60000 connections.max.idle.ms = 540000 ssl.truststore.password = null max.in.flight.requests.per.connection = 5 metrics.num.samples = 2 client.id = ssl.endpoint.identification.algorithm = null ssl.protocol = TLS request.timeout.ms = 30000 ssl.provider = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] acks = all batch.size = 16384 ssl.keystore.location = null receive.buffer.bytes = 32768 ssl.cipher.suites = null ssl.truststore.type = JKS security.protocol = PLAINTEXT retries = 0 max.request.size = 1048576 value.serializer = class org.apache.kafka.common.serialization.StringSerializer ssl.truststore.location = null ssl.keystore.password = null ssl.keymanager.algorithm = SunX509 metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner send.buffer.bytes = 131072 linger.ms = 1 *2016-04-04_10:07:52.551 WARN o.a.k.c.producer.ProducerConfig - The configuration serializer.class = org.apache.kafka.common.serialization.StringSerializer was supplied but isn't a known config.* 2016-04-04_10:07:52.553 INFO o.a.kafka.common.utils.AppInfoParser - Kafka version : 0.9.0.1 2016-04-04_10:07:52.553 INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId : 23c69d62a0cabf06 Here is my sample producer; package org.test; import java.io.IOException; import java.util.Properties; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerRecord; public class Producer { private void generateMessgaes() throws IOException { String topic = "LOB_TOPIC"; Properties props = new Properties(); props.put("bootstrap.servers", "xxx:9092"); props.put("acks", "all"); props.put("retries", 0); props.put("batch.size", 16384); props.put("linger.ms", 1); props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("serializer.class", "org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer<String, String> producer = null; try { producer = new KafkaProducer<>(props); for (int i = 0; i < 10; i++) { producer.send(new ProducerRecord<String, String>(topic, "test msg")); } } catch (Exception e) { e.printStackTrace(); System.out.println("Error in publishing messages to the topic : " + topic); } finally { producer.close(); } } public static void main(String[] args) throws IOException { Producer producer = new Producer(); producer.generateMessgaes(); System.out.println("$$$$$"); } } Thanks -- -Ratha http://vvratha.blogspot.com/