Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  1. Connect (port-forward) with the Kafka-connect server.

  2. Create a new connector with a POST API call to localhost:8083/connectors.

  3. The request body for that API call is written in the fileĀ file fiscal-event-mongodb-sink.

  4. Within that file, wherever ${---} replace it with the actual value based on the environment. Get ${mongo-db-authenticated-uri} from the configured secrets of the environment.
    (Optional) Verify and make changes to the topic names.

  5. The connector is ready. You can check it using API call GET localhost:8083/connectors.

...

  1. Open the Druid console

  2. Go to the Load Data section

  3. Select Other

  4. Click on Submit Supervisor

  5. Copy...Paste the JSON from the druid-ingestion-config.json file in the available text box.

  6. Verify the Kafka topic name and the Kafka bootstrap server address before submitting the config

  7. Submit the config and the data ingestion should start into the fiscal-event data source

...