[GitHub] [kafka] hachikuji commented on a change in pull request #9979: KAFKA-12238; Implement `DescribeProducers` API from KIP-664

2021-01-27 Thread GitBox
hachikuji commented on a change in pull request #9979: URL: https://github.com/apache/kafka/pull/9979#discussion_r565525057 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -3365,6 +3366,44 @@ class KafkaApis(val requestChannel: RequestChannel, } }

[GitHub] [kafka] hachikuji commented on a change in pull request #9979: KAFKA-12238; Implement `DescribeProducers` API from KIP-664

2021-01-27 Thread GitBox
hachikuji commented on a change in pull request #9979: URL: https://github.com/apache/kafka/pull/9979#discussion_r565519812 ## File path: clients/src/main/resources/common/message/DescribeProducersResponse.json ## @@ -0,0 +1,46 @@ +// Licensed to the Apache Software

[GitHub] [kafka] hachikuji commented on a change in pull request #9979: KAFKA-12238; Implement `DescribeProducers` API from KIP-664

2021-01-27 Thread GitBox
hachikuji commented on a change in pull request #9979: URL: https://github.com/apache/kafka/pull/9979#discussion_r565517686 ## File path: clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java ## @@ -511,6 +513,9 @@ public void testSerialization()