Hi, I am in the process of writing a consumer using the binary protocol and I am having issues where the fetch request will only return 10 messages.
Here is the code that I am using, so you can see the values (there are no settings hidden underneath): var frb = new FetchRequestBuilder() .SetReplicaId(-1) .SetMaxWaitTime(100) .SetMinBytes(0) .BuildTopic(topic) .AddPartition(partitionId, earliestOffset, Int32.MaxValue) .Continue() .GetMessage(); Any ideas why this would be. We have the default confluent platform installed version 2. Thanks Heath Ivie Warning: This e-mail may contain information proprietary to AutoAnything Inc. and is intended only for the use of the intended recipient(s). If the reader of this message is not the intended recipient(s), you have received this message in error and any review, dissemination, distribution or copying of this message is strictly prohibited. If you have received this message in error, please notify the sender immediately and delete all copies.