guohailong comments

Repositories
Issues
Comments

Results 2 comments of


                                            guohailong

How do I specify partitions for production messages

msg := &sarama.ProducerMessage{ Topic: "example-topic", Partition: 0, Value: sarama.StringEncoder("Hello, Kafka! - 1, i: " + string(i)), } I specified it explicitly, but it didn't work

How do I specify partitions for production messages

2024/03/30 21:54:46 Message sent to partition 0 at offset 28640 2024/03/30 21:54:47 Message sent to partition 0 at offset 28642 2024/03/30 21:54:48 Message sent to partition 1 at offset 15024...