Skip to content

Commit

Permalink
[FLINK-27480][kafka] Explain possible metrics InstanceAlreadyExistsEx…
Browse files Browse the repository at this point in the history
…ception in docs
  • Loading branch information
fapaul committed May 9, 2022
1 parent 358c1e4 commit f723242
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions docs/content/docs/connectors/datastream/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -307,6 +307,13 @@ For metrics of Kafka consumer, you can refer to
<a href="http://kafka.apache.org/documentation/#consumer_monitoring">Apache Kafka Documentation</a>
for more details.

In case you experience a warning with a stack trace containing
`javax.management.InstanceAlreadyExistsException: kafka.consumer:[...]`, you are probably trying to
register multiple ```KafkaConsumers``` with the same client.id. The warning indicates that not all
available metrics are correctly forwarded to the metrics system. You must ensure that a different
```client.id.prefix``` for every ```KafkaSource``` is configured and that no other
```KafkaConsumer``` in your job uses the same ```client.id```.

### Behind the Scene
{{< hint info >}}
If you are interested in how Kafka source works under the design of new data source API, you may
Expand Down

0 comments on commit f723242

Please sign in to comment.