This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new be116155642 MINOR: Remove duplicate method (#17291)
be116155642 is described below
commit be1161556423e5c30232a75a2d084cce1a5ecd57
Author: Lianet Magrans <[email protected]>
AuthorDate: Thu Sep 26 16:39:26 2024 -0400
MINOR: Remove duplicate method (#17291)
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
b/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
index 164ea05113e..de9c934190f 100644
---
a/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
+++
b/clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
@@ -2574,10 +2574,6 @@ public class KafkaConsumerTest {
return request.get();
}
- private boolean requestGenerated(MockClient client, ApiKeys apiKey) {
- return client.requests().stream().anyMatch(request ->
request.requestBuilder().apiKey().equals(apiKey));
- }
-
private KafkaConsumer<String, String>
consumerWithPendingAuthenticationError(GroupProtocol groupProtocol,
final Time time) {
ConsumerMetadata metadata = createMetadata(subscription);