Re: Why the consumer can't receve the message if fetch_size=1

2015-02-03 Thread Yury Ruchin
The fetch request size should not be less than the maximum message size. Apparently, all your messages are larger than 1 byte, so when you set fetch size to 1, your consumer is unable to fetch anything. 2015-02-03 10:53 GMT+03:00 Honda Wei ( 魏宏達 ) : > Hi Kafka Team > > I write some simple program

Why the consumer can't receve the message if fetch_size=1

2015-02-03 Thread 魏宏達
Hi Kafka Team I write some simple program and find a strange issue. Why the consumer can’t receive the message if the fetch is set to 1 , but when the parameter set to 100. The consumer will receive the message normally. FetchRequest req = new FetchRequestBuilder() .clientId(clientName)