How do I specify partition when producing messages，I want to implement ordered messages

[gopherhiro]

[isaacd9]

You can use the lower level Connection APIs to do this: https://pkg.go.dev/github.com/segmentio/kafka-go#Conn.WriteMessages.

There's no real need to use the Writer API if you're going to handle all the production and consumption yourself.