diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java index fe11b268837c7..df2a52ecf7c18 100644 --- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java +++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java @@ -32,7 +32,7 @@ public class StatefulProcessorNode extends ProcessorGraphNode { /** - * Create a node representing a stateful procssor, where the named store has already been registered. + * Create a node representing a stateful processor, where the named store has already been registered. */ public StatefulProcessorNode(final String nodeName, final ProcessorParameters processorParameters, @@ -48,7 +48,7 @@ public StatefulProcessorNode(final String nodeName, /** - * Create a node representing a stateful procssor, + * Create a node representing a stateful processor, * where the store needs to be built and registered as part of building this node. */ public StatefulProcessorNode(final String nodeName,