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 f5438f167ce53..b166d76bf8d58 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 @@ -951,24 +951,24 @@ default ListConsumerGroupOffsetsResult listConsumerGroupOffsets(MapNote: 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) { @@ -993,17 +993,17 @@ default DeleteConsumerGroupsResult deleteConsumerGroups(Collection group } /** - * 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. */ @@ -1035,13 +1035,13 @@ default DeleteConsumerGroupOffsetsResult deleteConsumerGroupOffsets(String group } /** - * 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, @@ -1049,7 +1049,7 @@ DeleteStreamsGroupOffsetsResult deleteStreamsGroupOffsets(String groupId, 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 c3fb9babb9a97..8e400354e0661 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 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 @@ ListStreamsGroupOffsetsSpec topicPartitions(Collection topicPart } /** - * 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 8f7d08e23a596..1447c92799693 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 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 d562fc754f43a..fed95a6b46fa9 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 int hashCode() { 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 b8a5db79445b4..55de41d77a529 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.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 1ca51cca62e85..8d6564083ff94 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 @@ private void process(final LeaveGroupOnCloseEvent event) { CompletableFuture 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 c3387859bc774..2e4aa42907a55 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 @@ -1643,7 +1643,7 @@ private void throwIfStreamsGroupIsFull( /** * 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. @@ -1798,7 +1798,7 @@ private static ConsumerProtocolSubscription deserializeSubscription( } /** - * 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 void replay( /** * 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 8b475241e2efa..c440deaa1a966 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.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 boolean isReconciledTo(int targetAssignmentEpoch) { } /** - * 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 99953b09d7159..71ee8c4ff30da 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.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 caa82ed2cb21c..7479fcae0fc2d 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.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 d56a8d0d71bf5..2902e647382f7 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.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.