example: https://github.com/confluentinc/confluent-kafka-go/blob/e01dd295220b5bf55f3fbfabdf8cc6d3f0ae185f/examples/cooperative_consumer_example/cooperative_consumer_example.go#L121.

Used for on-prem KafkaRest commands Embedded KafkaRest uses /kafka/v3 and standalone uses /v3 Relying on users to include the /kafka in the url for embedded instances.

validate that a topic exists before attempting to produce/consume messages.

EOF Unicode encoding for Ctrl+D (^D) character.

ACLConfiguration wrapper used for flag parsing and validation.

GroupHandler instances are used to handle individual topic-partition claims.