Codebase list golang-github-confluentinc-confluent-kafka-go / debian/0.11.0-2 examples
debian/0.11.0-2

Tree @debian/0.11.0-2 (Download .tar.gz)

Examples:

  consumer_channel_example - Channel based consumer
  consumer_example - Function & callback based consumer

  producer_channel_example - Channel based producer
  producer_example - Function based producer

  go-kafkacat - Channel based kafkacat Go clone


Usage example:

    $ cd consumer_example
    $ go build   (or 'go install')
    $ ./consumer_example    # see usage
    $ ./consumer_example mybroker mygroup mytopic