unable to get goka running with the following error.

[shubham7saxena]

Error creating processor: topic group-1-table has 50 partitions instead of 400 exit status 1

I see that this configuration comes from sarama. any particular reason I could be facing this.

[db7]

The error is saying that your group-table has only 50 partitions (perhaps the default of your Kafka configuration if you have auto.create.topics.enable=true?) instead of the 400 partitions that your input streams have. Perhaps we should make the error message a bit more informative.

In goka, the input topics, joined tables and group tables have to have the same number of partitions (be copartitioned). You can output, of course, into topics with different number of partitions than the input.

Regarding your group table, you have two options: either you create the group table by hand with the same number of partitions as the input streams, or you let goka create for you by passing a zookeeper-based topic manager as option. Perhaps the wiki page can help you further.

[db7]

@shubham7saxena any updates on this issue?

[db7]

I'm assuming this problem is not relevant anymore. Please reopen if needed.