Messages are not partitioned correctly and always ends in partition 0

[romain-gilles-ultra]

When you configure dkafka to push message from dfuse with a key mapping all the messages are pushed in the partition 0.

This issue was reported in the past at: confluentinc/confluent-kafka-go#474
If you don't provide the Partition property when you define the TopicPartition of a message then the message use the partition 0.

Solution

Specify Partition: kafka.PartitionAny to let kafka use the key to select the partition.