Hello. I’m having a problem with Kafka protocol API.
Requests: DescribeLogDirs Request (Version: 0) => [topics] topics => topic [partitions] topic => STRING partitions => INT32 My request contains `[{topic: “blah”, partitions: [0,1,2,3,4,5,6,7,8,9]}]`, but the result Responses: DescribeLogDirs Response (Version: 0) => throttle_time_ms [results] throttle_time_ms => INT32 results => error_code log_dir [topics] error_code => INT16 log_dir => STRING topics => name [partitions] name => STRING partitions => partition_index partition_size offset_lag is_future_key partition_index => INT32 partition_size => INT64 offset_lag => INT64 is_future_key => BOOLEAN contains entries for *all* topics. My workaround had been to filter the returned list by topic name to find the one I was requesting the data for, but I don’t understand why it’s not limiting the results to just the topic I requested in the first place. Also, I think there should be an option to just specify ALL_PARTITIONS because that would save me from having to retrieve topic metadata from the broker to count the number of partitions. Kafka server would probably have means to do that more efficiently. Is this a bug or am I doing something wrong? Thanks, Maxim ________________________________ COGILITY SOFTWARE CORPORATION LEGAL DISCLAIMER: The information in this email is confidential and is intended solely for the addressee. Access to this email by anyone else is unauthorized. If you are not the intended recipient, any disclosure, copying, distribution or any action taken or omitted to be taken in reliance on it, is prohibited and may be unlawful.