Random kafka partitioning is not working

[simPod]

Describe the bug

Currently, goflow produces to single partition. I tried enabling hashing in order to achieve random partitioning but it seems to have no effect.

To Reproduce

-transport.kafka.hashing=true

(

 -transport.kafka.brokers=... \
 -transport.kafka.version=3.5.0 \
 -transport.kafka.hashing=1 \
 -format=bin \
 -listen 'sflow://:1234?count=16'

)

goflow2/transport/kafka/kafka.go

Line 156 in a1750f5

kafkaConfig.Producer.Partitioner = sarama.NewHashPartitioner

But maybe the key is not nil by default? 🤔

https://github.com/IBM/sarama/blob/d09a287f30bdf73b1c9f53c3f7a4b2ecc2bd41d3/partitioner.go#L171-L174

Expected behavior

Messages produces to all partitions in the topic randomly

GoFlow2:

• v2.0.0
• debian pkg
• OS: linux debian

[simPod]

It also seems setting transport.kafka.hashing=1 is redundant as the NewHashPartitioner is default

[lspgn]

Thanks for the report! will have a look

[LeoAquarius]

May be the type ProtoProducerMessage struct function baseKey(h hash.Hash) had m.formatter == nil || len(m.formatter.key) == 0.

[lspgn]

Hoping to fix with #246

[lspgn]

Should be fixed. Let me know if still having the issue.