diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/Admin.java b/clients/src/main/java/org/apache/kafka/clients/admin/Admin.java index 3f90405bc65..e596754f62f 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/Admin.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/Admin.java @@ -950,24 +950,24 @@ public interface Admin extends AutoCloseable { } /** - * List the Streams group offsets available in the cluster for the specified Streams groups. + * List the streams group offsets available in the cluster for the specified streams groups. * * Note: this method effectively does the same as the corresponding consumer group method {@link Admin#listConsumerGroupOffsets} does. * - * @param groupSpecs Map of Streams group ids to a spec that specifies the topic partitions of the group to list offsets for. + * @param groupSpecs Map of streams group ids to a spec that specifies the topic partitions of the group to list offsets for. * - * @param options The options to use when listing the Streams group offsets. + * @param options The options to use when listing the streams group offsets. * @return The ListStreamsGroupOffsetsResult */ ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map groupSpecs, ListStreamsGroupOffsetsOptions options); /** - * List the Streams group offsets available in the cluster for the specified groups with the default options. + * List the streams group offsets available in the cluster for the specified groups with the default options. *

* This is a convenience method for * {@link #listStreamsGroupOffsets(Map, ListStreamsGroupOffsetsOptions)} with default options. * - * @param groupSpecs Map of Streams group ids to a spec that specifies the topic partitions of the group to list offsets for. + * @param groupSpecs Map of streams group ids to a spec that specifies the topic partitions of the group to list offsets for. * @return The ListStreamsGroupOffsetsResult. */ default ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map groupSpecs) { @@ -992,17 +992,17 @@ public interface Admin extends AutoCloseable { } /** - * Delete Streams groups from the cluster. + * Delete streams groups from the cluster. * * Note: this method effectively does the same as the corresponding consumer group method {@link Admin#deleteConsumerGroups} does. * - * @param options The options to use when deleting a Streams group. + * @param options The options to use when deleting a streams group. * @return The DeleteStreamsGroupsResult. */ DeleteStreamsGroupsResult deleteStreamsGroups(Collection groupIds, DeleteStreamsGroupsOptions options); /** - * Delete Streams groups from the cluster with the default options. + * Delete streams groups from the cluster with the default options. * * @return The DeleteStreamsGroupResult. */ @@ -1034,13 +1034,13 @@ public interface Admin extends AutoCloseable { } /** - * Delete committed offsets for a set of partitions in a Streams group. This will + * Delete committed offsets for a set of partitions in a streams group. This will * succeed at the partition level only if the group is not actively subscribed * to the corresponding topic. * * Note: this method effectively does the same as the corresponding consumer group method {@link Admin#deleteConsumerGroupOffsets} does. * - * @param options The options to use when deleting offsets in a Streams group. + * @param options The options to use when deleting offsets in a streams group. * @return The DeleteStreamsGroupOffsetsResult. */ DeleteStreamsGroupOffsetsResult deleteStreamsGroupOffsets(String groupId, @@ -1048,7 +1048,7 @@ public interface Admin extends AutoCloseable { DeleteStreamsGroupOffsetsOptions options); /** - * Delete committed offsets for a set of partitions in a Streams group with the default + * Delete committed offsets for a set of partitions in a streams group with the default * options. This will succeed at the partition level only if the group is not actively * subscribed to the corresponding topic. * diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java b/clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java index c3fb9babb9a..8e400354e06 100644 --- a/clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java +++ b/clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java @@ -23,7 +23,7 @@ import org.apache.kafka.common.annotation.InterfaceStability; import java.util.Collection; /** - * Specification of Streams group offsets to list using {@link Admin#listStreamsGroupOffsets(Map, ListStreamsGroupOffsetsOptions)}. + * Specification of streams group offsets to list using {@link Admin#listStreamsGroupOffsets(Map, ListStreamsGroupOffsetsOptions)}. *

* The API of this class is evolving, see {@link Admin} for details. */ @@ -33,7 +33,7 @@ public class ListStreamsGroupOffsetsSpec { private Collection topicPartitions; /** - * Set the topic partitions whose offsets are to be listed for a Streams group. + * Set the topic partitions whose offsets are to be listed for a streams group. */ ListStreamsGroupOffsetsSpec topicPartitions(Collection topicPartitions) { this.topicPartitions = topicPartitions; @@ -41,7 +41,7 @@ public class ListStreamsGroupOffsetsSpec { } /** - * Returns the topic partitions whose offsets are to be listed for a Streams group. + * Returns the topic partitions whose offsets are to be listed for a streams group. */ Collection topicPartitions() { return topicPartitions; diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java index 53e9ade43d1..7e83bc7a1e4 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java @@ -52,7 +52,7 @@ import java.util.stream.IntStream; import static org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.PollResult.EMPTY; /** - *

Manages the request creation and response handling for the Streams group heartbeat. The class creates a + *

Manages the request creation and response handling for the streams group heartbeat. The class creates a * heartbeat request using the state stored in the membership manager. The requests can be retrieved * by calling {@link StreamsGroupHeartbeatRequestManager#poll(long)}. Once the response is received, it updates the * state in the membership manager and handles any errors. diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java index d562fc754f4..fed95a6b46f 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java @@ -173,7 +173,7 @@ public class StreamsMembershipManager implements RequestManager { private MemberState state; /** - * Group ID of the Streams group the member will be part of, provided when creating the current + * Group ID of the streams group the member will be part of, provided when creating the current * membership manager. */ private final String groupId; diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java index b8a5db79445..55de41d77a5 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java @@ -20,7 +20,7 @@ import java.util.Optional; import java.util.Set; /** - * Listener for handling Streams group rebalance events in Kafka Streams. + * Listener for handling streams group rebalance events in Kafka Streams. */ public interface StreamsRebalanceListener { diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java index 1ca51cca62e..8d6564083ff 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java @@ -497,7 +497,7 @@ public class ApplicationEventProcessor implements EventProcessor future = requestManagers.consumerMembershipManager.get().leaveGroupOnClose(event.membershipOperation()); future.whenComplete(complete(event.future())); } else if (requestManagers.streamsMembershipManager.isPresent()) { - log.debug("Signal the StreamsMembershipManager to leave the Streams group since the member is closing"); + log.debug("Signal the StreamsMembershipManager to leave the streams group since the member is closing"); CompletableFuture future = requestManagers.streamsMembershipManager.get().leaveGroupOnClose(); future.whenComplete(complete(event.future())); } diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java index 0df0d09c57a..1dd7d2ed884 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java @@ -1630,7 +1630,7 @@ public class GroupMetadataManager { /** * Validates the member epoch provided in the heartbeat request. * - * @param member The Streams group member. + * @param member The streams group member. * @param receivedMemberEpoch The member epoch. * @param ownedActiveTasks The owned active tasks. * @param ownedStandbyTasks The owned standby tasks. @@ -1785,7 +1785,7 @@ public class GroupMetadataManager { } /** - * Handles a regular heartbeat from a Streams group member. + * Handles a regular heartbeat from a streams group member. * It mainly consists of five parts: * 1) Create or update the member. * The group epoch is bumped if the member has been created or updated. @@ -5248,8 +5248,8 @@ public class GroupMetadataManager { /** * Replays StreamsGroupMetadataKey/Value to update the hard state of - * the Streams group. It updates the group epoch of the Streams - * group or deletes the Streams group. + * the streams group. It updates the group epoch of the Streams + * group or deletes the streams group. * * @param key A StreamsGroupMetadataKey key. * @param value A StreamsGroupMetadataValue record. diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java index 8b475241e2e..c440deaa1a9 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java @@ -31,7 +31,7 @@ import java.util.Set; import java.util.stream.Collectors; /** - * Contains all information related to a member within a Streams group. + * Contains all information related to a member within a streams group. *

* This class is immutable and is fully backed by records stored in the __consumer_offsets topic. * @@ -322,7 +322,7 @@ public record StreamsGroupMember(String memberId, } /** - * Creates a member description for the Streams group describe response from this member. + * Creates a member description for the streams group describe response from this member. * * @param targetAssignment The target assignment of this member in the corresponding group. * diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java index 99953b09d71..71ee8c4ff30 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java @@ -23,7 +23,7 @@ import java.util.Optional; import java.util.Set; /** - * The assignment specification for a Streams group member. + * The assignment specification for a streams group member. * * @param instanceId The instance ID if provided. * @param rackId The rack ID if provided. diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java index caa82ed2cb2..7479fcae0fc 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java @@ -20,7 +20,7 @@ import java.util.Map; import java.util.Objects; /** - * The assignment specification for a Streams group. + * The assignment specification for a streams group. * * @param members The member metadata keyed by member ID. * @param assignmentConfigs Any configurations passed to the assignor. diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java index d56a8d0d71b..2902e647382 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java @@ -21,7 +21,7 @@ import java.util.Objects; import java.util.Set; /** - * The task assignment for a Streams group member. + * The task assignment for a streams group member. * * @param activeTasks The active tasks assigned to this member keyed by subtopologyId. * @param standbyTasks The standby tasks assigned to this member keyed by subtopologyId.