DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Under discussionVoting
Vote thread: https://lists.apache.org/thread/rysj5t3rfpz5pp1rjk0s7w9v7lq7dfpb
Discussion thread: https://lists.apache.org/thread/z8cwnksl6op4jfg7j0nwsg9xxsf8mwhh
...
Public Interfaces
Monitoring
| Name | Type | Description |
|---|---|---|
| kafka.controller:type=KafkaController,name=ControlledShutdownBrokerCount | Integer | The number of brokers currently in controlled shutdown. |
| kafka.controller:type=KafkaController,name=BrokerRegistrationState.kafka-X | Integer | A per-broker metric which displays the following values for the states:
This metric is removed when a broker is unregistered. This state is derived from the registration records contained in the metadata log. |
| kafka.controller:type=KafkaController,name=TimeSinceLastHeartbeatReceivedMs.kafka-X | Integer | A per-broker metric which reports the time in milliseconds since the last heartbeat received by the controller. The maximum value of this metric is the heartbeat timeout limit. Only the active controller reports this metric since it's soft state contained in BrokerHeartbeatTracker. |
Rationale
These metrics would be useful for monitoring the following use cases:
...
We will add junit tests to verify the new metrics.
Rejected Alternatives
| Name | Type | Description |
|---|---|---|
| kafka.controller:type=KafkaController,name=LongestPendingStartupTimeMs | Long | The duration, in milliseconds, of the longest pending broker startup. |
| kafka.controller:type=KafkaController,name=LongestPendingStartupBroker | String | The broker ID of the longest pending broker startup. |
| kafka.controller:type=KafkaController,name=NumberOfBrokersInStartup | Integer | The number of brokers currently starting up. |
| kafka.controller:type=KafkaController,name=LongestPendingControlledShudownTimeMs | Long | The duration, in milliseconds, of the longest pending broker controlled shutdown. |
| kafka.controller:type=KafkaController,name=LongestPendingControlledShutdownBroker | String | The broker ID of the longest pending broker controlled shutdown. |
| kafka.controller:type=KafkaController,name=NumberOfBrokersInControlledShutdown | Integer | The number of brokers currently in controlled shutdown. |
These duration metrics would rely on soft state, so they would be reset when controller failover occurs. This is a bit confusing, and the scope of these metrics is limited to startup and controlled shutdown scenarios. Instead, more general purpose metrics would be applicable across more use cases.
...