Hello there,
I am having issues about writing to same partition for different KEYs (should definitely not write to that partition because I have logged ChoosenPartition in logs) and writing to different partitions for same KEY and I checked that I have
'kafka_bridge.ekaf_partition_strategy = custom'
set on config
What do you suggest for me to do to be ensure if I have problem somewhere in my code or detect where might be not working as intended on ekaf library if any
Thank you for your time, have a good day