2020-08-06 16:38:53 -07:00
|
|
|
# Kafka, Zookeeper and Schema Registry
|
|
|
|
|
|
|
|
DataHub uses Kafka as the pub-sub message queue in the backend.
|
2025-04-16 16:55:51 -07:00
|
|
|
[Official Confluent Kafka Docker images](https://hub.docker.com/u/confluentinc) found in Docker Hub is used without
|
2020-08-06 16:38:53 -07:00
|
|
|
any modification.
|
|
|
|
|
|
|
|
## Debugging Kafka
|
2025-04-16 16:55:51 -07:00
|
|
|
|
2020-08-06 16:38:53 -07:00
|
|
|
You can install [kafkacat](https://github.com/edenhill/kafkacat) to consume and produce messaged to Kafka topics.
|
|
|
|
For example, to consume messages on MetadataAuditEvent topic, you can run below command.
|
2025-04-16 16:55:51 -07:00
|
|
|
|
2020-08-06 16:38:53 -07:00
|
|
|
```
|
|
|
|
kafkacat -b localhost:9092 -t MetadataAuditEvent
|
|
|
|
```
|
2025-04-16 16:55:51 -07:00
|
|
|
|
|
|
|
However, `kafkacat` currently doesn't support Avro deserialization at this point,
|
|
|
|
but they have an ongoing [work](https://github.com/edenhill/kafkacat/pull/151) for that.
|