Kafka producer failed to send but actually does

[Arunkumar Srambikkal (asrambik)]

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")