JimmyWang6 commented on code in PR #18819:
URL: https://github.com/apache/kafka/pull/18819#discussion_r1954284729
##########
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java:
##########
@@ -1780,6 +1780,33 @@ RemoveRaftVoterResult removeRaftVoter(
DescribeShareGroupsResult describeShareGroups(Collection<String> groupIds,
DescribeShareGroupsOptions
options);
+ /**
+ * Alters offsets for the specified group. In order to succeed, the group
must be empty.
+ *
+ * <p>This operation is not transactional, so it may succeed for some
partitions while fail for others.
+ *
+ * @param groupId The group for which to alter offsets.
+ * @param offsets A map of offsets by partition. Partitions not specified
in the map are ignored.
+ * @param options The options to use when altering the offsets.
+ * @return The AlterShareGroupOffsetsResult.
+ */
+ AlterShareGroupOffsetsResult alterShareGroupOffsets(String groupId,
Map<TopicPartition, Long> offsets, AlterShareGroupOffsetsOptions options);
+
Review Comment:
Fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
