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/

Reply via email to