Closed dennisqian1 closed 8 years ago
Paste the part where you configure the partitions please.
~B
On 18-Jul-2016, at 9:25 PM, Dennis Qian notifications@github.com wrote:
I tried to use different built-in partitioning strategy by setting "ekaf_partition_strategy" as ekaf's application environment variable in my app. But no strategy worked as expected. I also tried to set them via config file but that didn't help either. The end result is inconsistent distribution of messages onto partitions without any pattern. Most of the time ekaf does not write to all partitions but just some of them.
— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or mute the thread.
I tried to use different built-in partitioning strategy by setting "ekaf_partition_strategy" as ekaf's application environment variable in my app. But no strategy worked as expected. I also tried to set them via config file but that didn't help either. The end result is inconsistent distribution of messages onto partitions without any pattern. Most of the time ekaf does not write to all partitions but just some of them.