What's your configured required.acks? And also are you waiting for all your messages to be acknowledged as well?
The new producer returns futures back, but you still need to wait for the futures to complete. Tim On Fri, Jan 2, 2015 at 9:54 AM, Sa Li <sal...@gmail.com> wrote: > Hi, all > > We are sending the message from a producer, we send 100000 records, but we > see only 99573 records for that topics, we confirm this by consume this > topic and check the log size in kafka web console. > > Any ideas for the message lost, what is the reason to cause this? > > thanks > > -- > > Alec Li
