Skip to content

iceberg kafka metrics reporter #13291

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

blcksrx
Copy link

@blcksrx blcksrx commented Jun 10, 2025

Description

The KafkaMetricsReporter is a custom implementation of the MetricsReporter interface that allows reporting Iceberg metrics to a Kafka topic. This reporter is designed to serialize metrics reports into JSON format and send them as Kafka messages.

Motivation

This change introduces to address that gap by enabling:

  • Observable Metrics Pipelines: Metrics like ScanReport and CommitReport can now be serialized and emitted to a Kafka topic in real-time, making them consumable by monitoring systems, dashboards, or alerting tools.
  • Event-Driven Integration: By pushing metrics into Kafka, Iceberg actions can now trigger downstream workflows, such as audits, data lineage tracking, or compaction jobs via Kafka consumers.

Usage

To use the KafkaMetricsReporter, configure the following properties in your catalog:

metrics-reporter-impl=org.apache.iceberg.experimental.KafkaMetricsReporter
metrics-reporter.kafka.bootstrap.servers=localhost:9092
metrics-reporter.kafka.topic=iceberg-metrics

Signed-off-by: Hossein Torabi <[email protected]>
@blcksrx blcksrx force-pushed the kafka-metrics-reporter branch from 01b3d45 to 3deefd6 Compare June 10, 2025 17:50
@blcksrx
Copy link
Author

blcksrx commented Jun 11, 2025

@nastra appreciate your review and feedback

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant