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

MINOR: Change `Streams group` to `streams group` (#19813) 

As of https://github.com/apache/kafka/pull/19758#discussion_r2097734386,
the capitalization across all messages are aligned.

Reviewers: Lucas Brutschy <lbrutschy@confluent.io>, Andrew Schofield
 <aschofield@confluent.io>
This commit is contained in:
Alieh Saeedi 2025-05-28 09:56:29 +02:00 committed by GitHub
parent 591a24eaaf
commit a3d5ca07f8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
11 changed files with 27 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
View File

@ -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.
* *
* <em>Note</em>: this method effectively does the same as the corresponding consumer group method {@link Admin#listConsumerGroupOffsets} does. * <em>Note</em>: 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 * @return The ListStreamsGroupOffsetsResult
*/ */
ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map<String, ListStreamsGroupOffsetsSpec> groupSpecs, ListStreamsGroupOffsetsOptions options); ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map<String, ListStreamsGroupOffsetsSpec> 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.
* <p> * <p>
* This is a convenience method for * This is a convenience method for
* {@link #listStreamsGroupOffsets(Map, ListStreamsGroupOffsetsOptions)} with default options. * {@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. * @return The ListStreamsGroupOffsetsResult.
*/ */
default ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map<String, ListStreamsGroupOffsetsSpec> groupSpecs) { default ListStreamsGroupOffsetsResult listStreamsGroupOffsets(Map<String, ListStreamsGroupOffsetsSpec> groupSpecs) {
@ -992,17 +992,17 @@ public interface Admin extends AutoCloseable {
} }
/** /**
* Delete Streams groups from the cluster. * Delete streams groups from the cluster.
* *
* <em>Note</em>: this method effectively does the same as the corresponding consumer group method {@link Admin#deleteConsumerGroups} does. * <em>Note</em>: 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. * @return The DeleteStreamsGroupsResult.
*/ */
DeleteStreamsGroupsResult deleteStreamsGroups(Collection<String> groupIds, DeleteStreamsGroupsOptions options); DeleteStreamsGroupsResult deleteStreamsGroups(Collection<String> 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. * @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 * succeed at the partition level only if the group is not actively subscribed
* to the corresponding topic. * to the corresponding topic.
* *
* <em>Note</em>: this method effectively does the same as the corresponding consumer group method {@link Admin#deleteConsumerGroupOffsets} does. * <em>Note</em>: 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. * @return The DeleteStreamsGroupOffsetsResult.
*/ */
DeleteStreamsGroupOffsetsResult deleteStreamsGroupOffsets(String groupId, DeleteStreamsGroupOffsetsResult deleteStreamsGroupOffsets(String groupId,
@ -1048,7 +1048,7 @@ public interface Admin extends AutoCloseable {
DeleteStreamsGroupOffsetsOptions options); 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 * options. This will succeed at the partition level only if the group is not actively
* subscribed to the corresponding topic. * subscribed to the corresponding topic.
* *

6
clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsSpec.java
View File

@ -23,7 +23,7 @@ import org.apache.kafka.common.annotation.InterfaceStability;
import java.util.Collection; 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)}.
* <p> * <p>
* The API of this class is evolving, see {@link Admin} for details. * The API of this class is evolving, see {@link Admin} for details.
*/ */
@ -33,7 +33,7 @@ public class ListStreamsGroupOffsetsSpec {
private Collection<TopicPartition> topicPartitions; private Collection<TopicPartition> 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<TopicPartition> topicPartitions) { ListStreamsGroupOffsetsSpec topicPartitions(Collection<TopicPartition> topicPartitions) {
this.topicPartitions = 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<TopicPartition> topicPartitions() { Collection<TopicPartition> topicPartitions() {
return topicPartitions; return topicPartitions;

2
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java
View File

@ -52,7 +52,7 @@ import java.util.stream.IntStream;
import static org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.PollResult.EMPTY; import static org.apache.kafka.clients.consumer.internals.NetworkClientDelegate.PollResult.EMPTY;
/** /**
* <p>Manages the request creation and response handling for the Streams group heartbeat. The class creates a * <p>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 * 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 * by calling {@link StreamsGroupHeartbeatRequestManager#poll(long)}. Once the response is received, it updates the
* state in the membership manager and handles any errors. * state in the membership manager and handles any errors.

2
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java
View File

@ -173,7 +173,7 @@ public class StreamsMembershipManager implements RequestManager {
private MemberState state; 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. * membership manager.
*/ */
private final String groupId; private final String groupId;

2
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceListener.java
View File

@ -20,7 +20,7 @@ import java.util.Optional;
import java.util.Set; 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 { public interface StreamsRebalanceListener {

2
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java
View File

@ -497,7 +497,7 @@ public class ApplicationEventProcessor implements EventProcessor<ApplicationEven
CompletableFuture<Void> future = requestManagers.consumerMembershipManager.get().leaveGroupOnClose(event.membershipOperation()); CompletableFuture<Void> future = requestManagers.consumerMembershipManager.get().leaveGroupOnClose(event.membershipOperation());
future.whenComplete(complete(event.future())); future.whenComplete(complete(event.future()));
} else if (requestManagers.streamsMembershipManager.isPresent()) { } 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<Void> future = requestManagers.streamsMembershipManager.get().leaveGroupOnClose(); CompletableFuture<Void> future = requestManagers.streamsMembershipManager.get().leaveGroupOnClose();
future.whenComplete(complete(event.future())); future.whenComplete(complete(event.future()));
} }

8
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
View File

@ -1630,7 +1630,7 @@ public class GroupMetadataManager {
/** /**
* Validates the member epoch provided in the heartbeat request. * 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 receivedMemberEpoch The member epoch.
* @param ownedActiveTasks The owned active tasks. * @param ownedActiveTasks The owned active tasks.
* @param ownedStandbyTasks The owned standby 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: * It mainly consists of five parts:
* 1) Create or update the member. * 1) Create or update the member.
* The group epoch is bumped if the member has been created or updated. * 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 * Replays StreamsGroupMetadataKey/Value to update the hard state of
* the Streams group. It updates the group epoch of the Streams * the streams group. It updates the group epoch of the Streams
* group or deletes the Streams group. * group or deletes the streams group.
* *
* @param key A StreamsGroupMetadataKey key. * @param key A StreamsGroupMetadataKey key.
* @param value A StreamsGroupMetadataValue record. * @param value A StreamsGroupMetadataValue record.

4
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java
View File

@ -31,7 +31,7 @@ import java.util.Set;
import java.util.stream.Collectors; 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.
* <p> * <p>
* This class is immutable and is fully backed by records stored in the __consumer_offsets topic. * 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. * @param targetAssignment The target assignment of this member in the corresponding group.
* *

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java
View File

@ -23,7 +23,7 @@ import java.util.Optional;
import java.util.Set; 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 instanceId The instance ID if provided.
* @param rackId The rack ID if provided. * @param rackId The rack ID if provided.

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java
View File

@ -20,7 +20,7 @@ import java.util.Map;
import java.util.Objects; 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 members The member metadata keyed by member ID.
* @param assignmentConfigs Any configurations passed to the assignor. * @param assignmentConfigs Any configurations passed to the assignor.

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java
View File

@ -21,7 +21,7 @@ import java.util.Objects;
import java.util.Set; 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 activeTasks The active tasks assigned to this member keyed by subtopologyId.
* @param standbyTasks The standby tasks assigned to this member keyed by subtopologyId. * @param standbyTasks The standby tasks assigned to this member keyed by subtopologyId.