Thanks Jiangjie,
I too have thought the same after looking the code. Thanks a lot for
clearing my doubt!
On Tue, Mar 31, 2015 at 11:45 AM, Jiangjie Qin
wrote:
> The async send() put the message into a message queue then returns. When
> the messages are pulled out of the queue by the sender thre
The async send() put the message into a message queue then returns. When
the messages are pulled out of the queue by the sender thread, it still
uses SyncProducer to send ProducerRequests to brokers.
Jiangjie (Becket) Qin
On 3/30/15, 10:44 PM, "Madhukar Bharti" wrote:
>Hi All,
>
>I am using *as
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
