From 89724269c58cfff43c85500ff1f3c49066decc19 Mon Sep 17 00:00:00 2001 From: tabVersion Date: Fri, 20 Dec 2024 13:41:44 +0800 Subject: [PATCH] source side --- integrations/sources/kafka.mdx | 3 +++ 1 file changed, 3 insertions(+) diff --git a/integrations/sources/kafka.mdx b/integrations/sources/kafka.mdx index 24a423e6..7cefe479 100644 --- a/integrations/sources/kafka.mdx +++ b/integrations/sources/kafka.mdx @@ -92,6 +92,9 @@ When creating a source in RisingWave, you can specify the following Kafka parame | queued.min.messages | properties.queued.min.messages | int | | receive.message.max.bytes | properties.receive.message.max.bytes | int | | ssl.endpoint.identification.algorithm | properties.ssl.endpoint.identification.algorithm | str | +| statistics.interval.ms | properties.statistics.interval.ms | int | + +To monitor Kafka metrics in Grafana, set `properties.statistics.interval.ms` to a non-zero value. The granularity is 1000ms. The additional Kafka parameters `queued.min.messages` and `queued.max.messages.kbytes` are specified with `properties.queued.min.messages` and `properties.queued.max.messages.kbytes`, respectively, when creating the source.