You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In order to get more details about kafka partitions (such as their size) Kafka offers an admin request called "DescribeLogDirs". Sarama does not implement this request/response, but as it offers very valuable information we should add that request/response to Sarama.
The original Kafka documentation does not document the protocol but refers to the implementation:
In order to get more details about kafka partitions (such as their size) Kafka offers an admin request called "DescribeLogDirs". Sarama does not implement this request/response, but as it offers very valuable information we should add that request/response to Sarama.
The original Kafka documentation does not document the protocol but refers to the implementation:
Response package: https://github.com/apache/kafka/blob/05ba5aa00847b18b74369a821e972bbba9f155eb/clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java
Request package:
https://github.com/apache/kafka/blob/05ba5aa00847b18b74369a821e972bbba9f155eb/clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsRequest.java
The text was updated successfully, but these errors were encountered: