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
Versions
Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.
Sarama Version: a4a1b88
Kafka Version: 2.1.1
Go Version: 1.12.1
Versions
Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.
Sarama Version: a4a1b88
Kafka Version: 2.1.1
Go Version: 1.12.1
Configuration
Not relevant
Logs
Not relevant
Problem Description
The method DeleteRecords in admin.go seems to have a bug. The DeleteRecordsRequest should be sent to Leader according to KafkaAdminClient rather than the controller(https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java). Also the controller will respond with an error code 6 but the return error of the method is nil.
I'm going to fix it as below
The text was updated successfully, but these errors were encountered: