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/
