kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Arunkumar Srambikkal (asrambik)" <asram...@cisco.com>
Subject Kafka producer failed to send but actually does
Date Tue, 03 Mar 2015 12:01:01 GMT
Hi, 

I'm running some tests with the Kafka embedded broker and I see cases where the producer gets
the FailedToSendMessageException but in reality the message is transferred and consumer gets
it 

Is this expected / known issue? 

Thanks
Arun

My producer config = 

    props.put("producer.type",         "sync")
    props.put("serializer.class",      "kafka.serializer.StringEncoder");
    props.put("partitioner.class",     "com.test.PartMe");
    props.put("metadata.broker.list",  "127.0.0.1:"+port); 
    props.put("request.required.acks", "-1");   
    props.put("message.send.max.retries", "0")

Mime
View raw message