mirror of https://github.com/apache/kafka.git
44c6e956ed
CI / build (push) Waiting to run
Details
All state updater threads use the same metrics instance, but do not use unique names for their sensors. This can have the following symptoms: 1) Data inserted into one sensor by one thread can affect the metrics of all state updater threads. 2) If one state updater thread is shutdown, the metrics associated to all state updater threads are removed. 3) If one state updater thread is started, while another one is removed, it can happen that a metric is registered with the `Metrics` instance, but not associated to any `Sensor` (because it is concurrently removed), which means that the metric will not be removed upon shutdown. If a thread with the same name later tries to register the same metric, we may run into a `java.lang.IllegalArgumentException: A metric named ... already exists`, as described in the ticket. This change fixes the bug giving unique names to the sensors. A test is added that there is no interference of the removal of sensors and metrics during shutdown. Reviewers: Matthias J. Sax <matthias@confluent.io> |
||
|---|---|---|
| .. | ||
| examples/src | ||
| integration-tests/src/test | ||
| quickstart | ||
| src | ||
| streams-scala | ||
| test-utils/src | ||
| upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests | ||
| upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests | ||
| .gitignore | ||