MCE Consumer is a Kafka Streams job. Its main function is to listen
MetadataChangeEvent Kafka topic for messages and process those messages and writes new metadata to
After every successful update of metadata, GMS fires a
MetadataAuditEvent and this is consumed by
MAE Consumer Job.
- You need to have JDK8 installed on your machine to be
able to build
MCE Consumer Job is already built as part of top level build:
However, if you only want to build
MCE Consumer Job specifically:
Start via Docker image
Quickest way to try out
MCE Consumer Job is running the Docker image.
Start via command line
If you do modify things and want to try it out quickly without building the Docker image, you can also run the application directly from command line after a successful build:
To debug with an IDE (i.e. IntelliJ), run the
bootRun task with the
--debug-jvm flag. This will launch the app and
listen on port 5005 for a remote debugger.
./gradlew :metadata-jobs:mce-consumer-job:bootRun --debug-jvm
Spring boot actuator has been enabled for MCE Application.
info web endpoints are enabled by default.
healthcheck - http://localhost:9090/actuator/health
metrics - http://localhost:9090/actuator/metrics
To retrieve a specific metric - http://localhost:9090/actuator/metrics/kafka.consumer.records.consumed.total