root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: suppress deprecation warnings for MemberDescription (#18139) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
PoAn Yang 2024-12-12 01:05:31 +08:00 committed by GitHub
parent 23de98cdc5
commit 156d551603
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupServiceTest.java
View File

@ -103,6 +103,7 @@ public class ConsumerGroupServiceTest {
} }
@Test @Test
@SuppressWarnings("deprecation")
public void testAdminRequestsForDescribeNegativeOffsets() throws Exception { public void testAdminRequestsForDescribeNegativeOffsets() throws Exception {
String[] args = new String[]{"--bootstrap-server", "localhost:9092", "--group", GROUP, "--describe", "--offsets"}; String[] args = new String[]{"--bootstrap-server", "localhost:9092", "--group", GROUP, "--describe", "--offsets"};
ConsumerGroupCommand.ConsumerGroupService groupService = consumerGroupService(args); ConsumerGroupCommand.ConsumerGroupService groupService = consumerGroupService(args);
@ -232,6 +233,7 @@ public class ConsumerGroupServiceTest {
}; };
} }
@SuppressWarnings("deprecation")
private DescribeConsumerGroupsResult describeGroupsResult(GroupState groupState) { private DescribeConsumerGroupsResult describeGroupsResult(GroupState groupState) {
MemberDescription member1 = new MemberDescription("member1", Optional.of("instance1"), "client1", "host1", null); MemberDescription member1 = new MemberDescription("member1", Optional.of("instance1"), "client1", "host1", null);
ConsumerGroupDescription description = new ConsumerGroupDescription(GROUP, ConsumerGroupDescription description = new ConsumerGroupDescription(GROUP,