kafka.PartitionAny doesn't work for AWS MSK Kafka 2.2.1

[hapnermw]

Description

The example producer uses kafka.PartitionAny. In the context noted, this is interpreted as the -1 partition ID which is unknown. This likely fails in other contexts; however, this happens to be the context I'm using.

How to reproduce

Run the producer example on a vanilla AWS MKS Kafka 2.2.1 instance. Since the producer doesn't create a topic (which the example should fix) you will need to create the myTopic topic prior to running this.

Checklist

Please provide the following information:

• [ X] confluent-kafka-go and librdkafka version (LibraryVersion()):
• [ ] Apache Kafka broker version:
• [ ] Client configuration: ConfigMap{...}
• [ ] Operating system:
• [ ] Provide client logs (with "debug": ".." as necessary)
• [ ] Provide broker log excerpts
• [ ] Critical issue

[wedneyyuri]

Hi @hapnermw are you still seeing this problem?