Confluent Consume

Premium Partner

HTTP GETv3.10+

Configure the plugin to consume messages via HTTP GET requests.

Prerequisites

Environment variables

  • BOOTSTRAP_SERVER_HOST: The bootstrap server host

  • API_KEY: The API key to use for authentication.

  • API_SECRET: The API secret to use for authentication.

  • KAFKA_TOPIC: The name of the Kafka topic to consume from.

Set up the plugin

Add this section to your declarative configuration file:

_format_version: "3.0"
plugins:
  - name: confluent-consume
    config:
      bootstrap_servers:
      - host: ${{ env "DECK_BOOTSTRAP_SERVER_HOST" }}
        port: 9092
      topics:
      - name: ${{ env "DECK_KAFKA_TOPIC" }}
      mode: http-get
      cluster_api_key: ${{ env "DECK_API_KEY" }}
      cluster_api_secret: ${{ env "DECK_API_SECRET" }}
Copied to clipboard!

Did this doc help?

Something wrong?

Help us make these docs great!

Kong Developer docs are open source. If you find these useful and want to make them better, contribute today!