abiwill 7bbac5ef4d
feat(kafka-setup): add options for sasl_plaintext (#5385)
allow sasl_plaintext options using environment variables
2022-07-13 13:47:23 -07:00
..
2022-04-19 15:22:49 -07:00

Kafka, Zookeeper and Schema Registry

DataHub uses Kafka as the pub-sub message queue in the backend. Official Confluent Kafka Docker images found in Docker Hub is used without any modification.

Debugging Kafka

You can install kafkacat to consume and produce messaged to Kafka topics. For example, to consume messages on MetadataAuditEvent topic, you can run below command.

kafkacat -b localhost:9092 -t MetadataAuditEvent

However, kafkacat currently doesn't support Avro deserialization at this point, but they have an ongoing work for that.