Hi All, I am using *async *producer to send the data. When I checked the log it is showing as below:
[2015-03-31 11:09:55,915] INFO Verifying properties (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,946] INFO Property key.serializer.class is overridden to kafka.serializer.StringEncoder (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,947] INFO Property metadata.broker.list is overridden to 172.20.6.201:9092,172.20.6.25:9092,172.20.8.62:9092 (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,947] INFO Property producer.type is overridden to async (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,947] INFO Property queue.buffering.max.ms is overridden to 300 (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,947] INFO Property queue.enqueue.timeout.ms is overridden to 50 (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,947] INFO Property request.required.acks is overridden to 1 (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,948] INFO Property send.buffer.bytes is overridden to 4048 (kafka.utils.VerifiableProperties) [2015-03-31 11:09:55,948] INFO Property serializer.class is overridden to kafka.serializer.StringEncoder (kafka.utils.VerifiableProperties) Thread Number0 Sent: This is message 0, Topic::TestMQ Sent: This is message 1, Topic::TestMQ Sent: This is message 2, Topic::TestMQ Sent: This is message 3, Topic::TestMQ Sent: This is message 4, Topic::TestMQ Sent: This is message 5, Topic::TestMQ Sent: This is message 6, Topic::TestMQ Sent: This is message 7, Topic::TestMQ Sent: This is message 8, Topic::TestMQ Sent: This is message 9, Topic::TestMQ [2015-03-31 11:09:56,395] INFO Fetching metadata from broker id:1,host:172.20.6.25,port:9092 with correlation id 0 for 1 topic(s) Set(TestMQ) (kafka.client.ClientUtils$) [2015-03-31 11:09:56,404] INFO Connected to 172.20.6.25:9092 for producing (kafka.producer.SyncProducer) [2015-03-31 11:09:56,438] INFO Disconnecting from 172.20.6.25:9092 (kafka.producer.SyncProducer) [2015-03-31 11:09:56,479] INFO Connected to 172.20.6.25:9092 for producing (kafka.producer.SyncProducer) [2015-03-31 11:09:56,573] INFO Connected to 172.20.6.201:9092 for producing (kafka.producer.SyncProducer) [2015-03-31 11:09:56,591] INFO Connected to 172.20.8.62:9092 for producing (kafka.producer.SyncProducer) My doubt is why it is using "*kafka.producer.SyncProducer*"? I am using kafka 0.8.1.1. Thanks in advance!
