Skip to content

Commit

Permalink
source side
Browse files Browse the repository at this point in the history
  • Loading branch information
tabVersion committed Dec 20, 2024
1 parent 9f58e49 commit 8972426
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions integrations/sources/kafka.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand Down

0 comments on commit 8972426

Please sign in to comment.