Path	Lines of Code
streams/quickstart/java/src/main/resources/META-INF/maven/archetype-metadata.xml	17
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java	40
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java	36
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java	49
streams/quickstart/java/src/main/resources/archetype-resources/src/main/resources/log4j2.yaml	15
streams/src/main/java/org/apache/kafka/streams/AutoOffsetReset.java	49
streams/src/main/java/org/apache/kafka/streams/ClientInstanceIds.java	11
streams/src/main/java/org/apache/kafka/streams/GroupProtocol.java	13
streams/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	16
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	1397
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java	48
streams/src/main/java/org/apache/kafka/streams/KeyValue.java	32
streams/src/main/java/org/apache/kafka/streams/LagInfo.java	43
streams/src/main/java/org/apache/kafka/streams/StoreQueryParameters.java	61
streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java	176
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	1371
streams/src/main/java/org/apache/kafka/streams/StreamsMetadata.java	15
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	24
streams/src/main/java/org/apache/kafka/streams/TaskMetadata.java	15
streams/src/main/java/org/apache/kafka/streams/ThreadMetadata.java	14
streams/src/main/java/org/apache/kafka/streams/Topology.java	449
streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java	284
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	52
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	26
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.java	28
streams/src/main/java/org/apache/kafka/streams/errors/ErrorHandlerContext.java	19
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStoreException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/InvalidStateStorePartitionException.java	12
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	42
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueProcessingExceptionHandler.java	24
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	42
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailProcessingExceptionHandler.java	24
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java	7
streams/src/main/java/org/apache/kafka/streams/errors/ProcessingExceptionHandler.java	16
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	44
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreMigratedException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreNotAvailableException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	35
streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/StreamsRebalancingException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/StreamsStoppedException.java	12
streams/src/main/java/org/apache/kafka/streams/errors/StreamsUncaughtExceptionHandler.java	15
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java	19
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/TaskMigratedException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/TopologyException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/UnknownStateStoreException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/UnknownTopologyException.java	11
streams/src/main/java/org/apache/kafka/streams/errors/internals/DefaultErrorHandlerContext.java	74
streams/src/main/java/org/apache/kafka/streams/errors/internals/FailedProcessingException.java	17
streams/src/main/java/org/apache/kafka/streams/errors/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/internals/ApiUtils.java	44
streams/src/main/java/org/apache/kafka/streams/internals/AutoOffsetResetInternal.java	23
streams/src/main/java/org/apache/kafka/streams/internals/ClientInstanceIdsImpl.java	37
streams/src/main/java/org/apache/kafka/streams/internals/StreamsConfigUtils.java	51
streams/src/main/java/org/apache/kafka/streams/internals/UpgradeFromValues.java	39
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java	135
streams/src/main/java/org/apache/kafka/streams/internals/metrics/StreamsClientMetricsDelegatingReporter.java	48
streams/src/main/java/org/apache/kafka/streams/internals/metrics/StreamsThreadMetricsDelegatingReporter.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Branched.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/BranchedKStream.java	10
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java	125
streams/src/main/java/org/apache/kafka/streams/kstream/EmitStrategy.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachProcessor.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	104
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	86
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	37
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	183
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	175
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	144
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Named.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/NamedOperation.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	83
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java	62
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java	72
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	40
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java	78
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	61
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java	61
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java	266
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java	40
streams/src/main/java/org/apache/kafka/streams/kstream/TableJoined.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	38
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java	79
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	91
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	65
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	16
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	7
streams/src/main/java/org/apache/kafka/streams/kstream/Window.java	59
streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	11
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractConfigurableStoreFactory.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractKStreamTimeWindowAggregateProcessor.java	179
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/BranchedInternal.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/BranchedKStreamImpl.java	86
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	111
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	109
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java	119
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java	242
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ForeachProcessor.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullTimeWindowedSerde.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GlobalKTableImpl.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedInternal.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/GroupedStreamAggregateBuilder.java	121
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalNameProvider.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java	536
streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinWindowsInternal.java	10
streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	206
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	184
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java	138
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	1118
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java	211
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	41
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	218
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinLeftSide.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinRightSide.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java	109
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	138
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPrint.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java	133
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	312
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java	404
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	171
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	106
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	168
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	1174
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	43
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoinValueGetterSupplier.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableInnerJoin.java	141
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	112
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	148
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	156
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	139
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	149
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTablePassThrough.java	69
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableProcessorSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableReduce.java	98
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	150
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMapSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	138
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java	152
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	12
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java	72
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.java	92
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedStoreFactory.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/internals/NamedInternal.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/OuterStreamJoinStoreFactory.java	157
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PassThrough.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintForeachAction.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/PrintedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ProducedInternal.java	21
streams/src/main/java/org/apache/kafka/streams/kstream/internals/RepartitionedInternal.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionCacheFlushListener.java	26
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionStoreMaterializer.java	80
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindow.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedCogroupedKStreamImpl.java	81
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	205
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowStoreMaterializer.java	84
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java	70
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java	167
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedStoreFactory.java	121
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamStreamJoinUtil.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SubscriptionStoreFactory.java	83
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TableJoinedInternal.java	17
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedCogroupedKStreamImpl.java	72
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	192
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListener.java	37
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarder.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowStoreMaterializer.java	80
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedSerializer.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowedStreamPartitioner.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerde.java	41
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableUtils.java	71
streams/src/main/java/org/apache/kafka/streams/kstream/internals/emitstrategy/WindowCloseStrategy.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/internals/emitstrategy/WindowUpdateStrategy.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java	40
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKeySchema.java	68
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignKeyExtractor.java	13
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignTableJoinProcessorSupplier.java	112
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ResponseJoinProcessorSupplier.java	88
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinProcessorSupplier.java	96
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionReceiveProcessorSupplier.java	105
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java	69
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java	101
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionSendProcessorSupplier.java	165
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java	94
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java	188
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseJoinProcessorNode.java	51
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java	114
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ForeignJoinSubscriptionSendNode.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ForeignTableJoinNode.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java	54
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GracePeriodGraphNode.java	13
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtil.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphNode.java	118
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GroupedTableOperationRepartitionNode.java	89
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/KTableKTableJoinNode.java	163
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/NodesWithRelaxedNullKeyJoinDownstream.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java	80
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java	67
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorToStateConnectorNode.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/SourceGraphNode.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StateStoreNode.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java	62
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java	118
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamTableJoinNode.java	47
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java	18
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableFilterNode.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableRepartitionMapNode.java	19
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java	125
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSuppressNode.java	7
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java	71
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/VersionedSemanticsGraphNode.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/WindowedStreamProcessorNode.java	15
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferConfigInternal.java	29
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferFullStrategy.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/FinalResultsSuppressionBuilder.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/KTableSuppressProcessorSupplier.java	183
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/NamedSuppressed.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/StrictBufferConfigImpl.java	89
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/SuppressedInternal.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/TimeDefinitions.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	10
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	6
streams/src/main/java/org/apache/kafka/streams/processor/CommitCallback.java	8
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java	12
streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java	15
streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java	20
streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java	14
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	42
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	6
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	7
streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java	10
streams/src/main/java/org/apache/kafka/streams/processor/StandbyUpdateListener.java	22
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	5
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	19
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	31
streams/src/main/java/org/apache/kafka/streams/processor/StateStoreContext.java	26
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	8
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	95
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	7
streams/src/main/java/org/apache/kafka/streams/processor/To.java	51
streams/src/main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java	5
streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java	16
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	8
streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java	12
streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java	12
streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java	11
streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessorContext.java	5
streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessorSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyRecord.java	67
streams/src/main/java/org/apache/kafka/streams/processor/api/InternalFixedKeyRecordFactory.java	13
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessingContext.java	36
streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java	11
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java	5
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorWrapper.java	28
streams/src/main/java/org/apache/kafka/streams/processor/api/Record.java	73
streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java	8
streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedFixedKeyProcessorSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedProcessorSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/processor/api/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/processor/assignment/ApplicationState.java	9
streams/src/main/java/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.java	133
streams/src/main/java/org/apache/kafka/streams/processor/assignment/KafkaStreamsAssignment.java	93
streams/src/main/java/org/apache/kafka/streams/processor/assignment/KafkaStreamsState.java	19
streams/src/main/java/org/apache/kafka/streams/processor/assignment/ProcessId.java	37
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java	780
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignor.java	31
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskInfo.java	9
streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskTopicPartition.java	10
streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java	380
streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/processor/assignment/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractPartitionGroup.java	35
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	207
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java	251
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java	254
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	154
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java	236
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	15
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java	46
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java	9
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogTopics.java	102
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java	183
streams/src/main/java/org/apache/kafka/streams/processor/internals/ConfigurableStore.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/CorruptedRecord.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java	955
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamsRebalanceListener.java	99
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java	113
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	114
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java	444
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	135
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	354
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	50
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalResourcesNaming.java	44
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	64
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	738
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicProperties.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java	1852
streams/src/main/java/org/apache/kafka/streams/processor/internals/NoOpProcessorWrapper.java	50
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	286
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGrouper.java	65
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessingThread.java	4
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	292
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java	52
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorMetadata.java	91
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	215
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java	166
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	592
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	192
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	51
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java	69
streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java	39
streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java	187
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallback.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	473
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	99
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	153
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	57
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java	226
streams/src/main/java/org/apache/kafka/streams/processor/internals/SerdeGetter.java	23
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	83
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	71
streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java	34
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	245
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java	131
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	609
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	25
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java	119
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java	31
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java	92
streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java	33
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreBuilderWrapper.java	97
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	789
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreDelegatingProcessorSupplier.java	24
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreFactory.java	83
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	1027
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	1511
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThreadTotalBlockedTime.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	422
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java	1257
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java	244
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java	90
streams/src/main/java/org/apache/kafka/streams/processor/internals/SynchronizedPartitionGroup.java	72
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	103
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAndAction.java	58
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java	103
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java	218
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	1727
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskMetadataImpl.java	73
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java	262
streams/src/main/java/org/apache/kafka/streams/processor/internals/TasksRegistry.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadMetadataImpl.java	101
streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java	4
streams/src/main/java/org/apache/kafka/streams/processor/internals/ToInternal.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadata.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java	508
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedUnversionedChangelogTopicConfig.java	49
streams/src/main/java/org/apache/kafka/streams/processor/internals/VersionedChangelogTopicConfig.java	65
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	62
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	417
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java	166
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java	25
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/BalanceSubtopologyGraphConstructor.java	200
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	433
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTask.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java	256
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java	55
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConsumerProtocolUtils.java	77
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java	135
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultApplicationState.java	62
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultKafkaStreamsState.java	129
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultStandbyTaskAssignor.java	34
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultTaskInfo.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultTaskTopicPartition.java	66
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java	21
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java	406
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java	231
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignor.java	302
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/LegacyTaskAssignor.java	13
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/MinTrafficGraphConstructor.java	108
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructor.java	106
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructorFactory.java	42
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java	392
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackUtils.java	118
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ReferenceContainer.java	23
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignmentUtils.java	44
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignor.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignorFactory.java	24
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java	8
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	309
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java	253
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java	177
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java	829
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java	303
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java	341
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TopicMetrics.java	68
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/AddNamedTopologyResult.java	28
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java	265
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopology.java	23
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyBuilder.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStoreQueryParameters.java	50
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/RemoveNamedTopologyResult.java	74
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java	244
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManager.java	294
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskExecutor.java	14
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskExecutorCreator.java	6
streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskManager.java	28
streams/src/main/java/org/apache/kafka/streams/processor/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/query/FailureReason.java	11
streams/src/main/java/org/apache/kafka/streams/query/KeyQuery.java	25
streams/src/main/java/org/apache/kafka/streams/query/MultiVersionedKeyQuery.java	47
streams/src/main/java/org/apache/kafka/streams/query/Position.java	93
streams/src/main/java/org/apache/kafka/streams/query/PositionBound.java	42
streams/src/main/java/org/apache/kafka/streams/query/Query.java	3
streams/src/main/java/org/apache/kafka/streams/query/QueryConfig.java	12
streams/src/main/java/org/apache/kafka/streams/query/QueryResult.java	52
streams/src/main/java/org/apache/kafka/streams/query/RangeQuery.java	42
streams/src/main/java/org/apache/kafka/streams/query/ResultOrder.java	6
streams/src/main/java/org/apache/kafka/streams/query/StateQueryRequest.java	122
streams/src/main/java/org/apache/kafka/streams/query/StateQueryResult.java	57
streams/src/main/java/org/apache/kafka/streams/query/TimestampedKeyQuery.java	27
streams/src/main/java/org/apache/kafka/streams/query/TimestampedRangeQuery.java	44
streams/src/main/java/org/apache/kafka/streams/query/VersionedKeyQuery.java	29
streams/src/main/java/org/apache/kafka/streams/query/WindowKeyQuery.java	40
streams/src/main/java/org/apache/kafka/streams/query/WindowRangeQuery.java	41
streams/src/main/java/org/apache/kafka/streams/query/internals/AbstractQueryResult.java	29
streams/src/main/java/org/apache/kafka/streams/query/internals/FailedQueryResult.java	40
streams/src/main/java/org/apache/kafka/streams/query/internals/InternalQueryResultUtil.java	22
streams/src/main/java/org/apache/kafka/streams/query/internals/SucceededQueryResult.java	47
streams/src/main/java/org/apache/kafka/streams/query/package-info.java	1
streams/src/main/java/org/apache/kafka/streams/state/BuiltInDslStoreSuppliers.java	69
streams/src/main/java/org/apache/kafka/streams/state/DslKeyValueParams.java	40
streams/src/main/java/org/apache/kafka/streams/state/DslSessionParams.java	53
streams/src/main/java/org/apache/kafka/streams/state/DslStoreSuppliers.java	12
streams/src/main/java/org/apache/kafka/streams/state/DslWindowParams.java	93
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	62
streams/src/main/java/org/apache/kafka/streams/state/KeyValueBytesStoreSupplier.java	4
streams/src/main/java/org/apache/kafka/streams/state/KeyValueIterator.java	9
streams/src/main/java/org/apache/kafka/streams/state/KeyValueStore.java	11
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	9
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	101
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	18
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	79
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	10
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	71
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	95
streams/src/main/java/org/apache/kafka/streams/state/StoreBuilder.java	13
streams/src/main/java/org/apache/kafka/streams/state/StoreSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/state/Stores.java	213
streams/src/main/java/org/apache/kafka/streams/state/TimestampedBytesStore.java	15
streams/src/main/java/org/apache/kafka/streams/state/TimestampedKeyValueStore.java	2
streams/src/main/java/org/apache/kafka/streams/state/TimestampedWindowStore.java	3
streams/src/main/java/org/apache/kafka/streams/state/ValueAndTimestamp.java	49
streams/src/main/java/org/apache/kafka/streams/state/VersionedBytesStore.java	7
streams/src/main/java/org/apache/kafka/streams/state/VersionedBytesStoreSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/state/VersionedKeyValueStore.java	11
streams/src/main/java/org/apache/kafka/streams/state/VersionedRecord.java	47
streams/src/main/java/org/apache/kafka/streams/state/VersionedRecordIterator.java	7
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	8
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	79
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStore.java	250
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	142
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java	327
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBTimeOrderedSegmentedBytesStore.java	200
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java	189
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractStoreBuilder.java	63
streams/src/main/java/org/apache/kafka/streams/state/internals/BatchWritingStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/internals/BlockBasedTableConfigWithAccessibleCache.java	14
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferKey.java	45
streams/src/main/java/org/apache/kafka/streams/state/internals/BufferValue.java	120
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFlushListener.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CacheFunction.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachedStateStore.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	430
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	410
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java	473
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java	95
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingListValueBytesStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	77
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java	22
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingVersionedKeyValueBytesStore.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	100
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeKeyValueIterator.java	41
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyKeyValueStore.java	135
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	206
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	152
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java	52
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	56
streams/src/main/java/org/apache/kafka/streams/state/internals/ExceptionUtils.java	26
streams/src/main/java/org/apache/kafka/streams/state/internals/FilteredCacheIterator.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/GlobalStateStoreProvider.java	33
streams/src/main/java/org/apache/kafka/streams/state/internals/HasNextCondition.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueBytesStoreSupplier.java	22
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java	237
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionBytesStoreSupplier.java	33
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java	458
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBuffer.java	431
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.java	60
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java	548
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIteratorFacade.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueIterators.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegment.java	53
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreWrapper.java	105
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java	171
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueIteratorAdapter.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	61
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValue.java	49
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValueDeserializer.java	46
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerde.java	15
streams/src/main/java/org/apache/kafka/streams/state/internals/LeftOrRightValueSerializer.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/ListValueStore.java	111
streams/src/main/java/org/apache/kafka/streams/state/internals/ListValueStoreBuilder.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegment.java	275
streams/src/main/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegments.java	88
streams/src/main/java/org/apache/kafka/streams/state/internals/LogicalSegmentIterator.java	94
streams/src/main/java/org/apache/kafka/streams/state/internals/ManagedKeyValueIterator.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/Maybe.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java	164
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	122
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheKeyValueBytesStoreIterator.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheSessionStoreIterator.java	40
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	45
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	73
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredIterator.java	4
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	459
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredMultiVersionedKeyQueryIterator.java	57
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	444
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java	316
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java	29
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredVersionedKeyValueStore.java	293
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	458
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	71
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	80
streams/src/main/java/org/apache/kafka/streams/state/internals/Murmur3.java	367
streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java	329
streams/src/main/java/org/apache/kafka/streams/state/internals/NextIteratorFunction.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/OffsetCheckpoint.java	133
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/PositionSerde.java	73
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedSessionKeySchemas.java	297
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java	310
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	33
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacade.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacade.java	88
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverter.java	5
streams/src/main/java/org/apache/kafka/streams/state/internals/RecordConverters.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java	1435
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBKeyValueBytesStoreSupplier.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java	61
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSegmentedBytesStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java	119
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	793
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java	283
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBytesStore.java	58
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBytesStoreSupplier.java	19
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSegmentedBytesStore.java	122
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStore.java	128
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowSegmentedBytesStore.java	90
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedWindowStore.java	156
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedSegmentedBytesStore.java	10
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedStore.java	391
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedWindowStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java	616
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreRestoreWriteBuffer.java	170
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java	358
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	107
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIndexedTimeOrderedWindowBytesStoreSupplier.java	134
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java	63
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbTimeOrderedSessionBytesStoreSupplier.java	44
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbVersionedKeyValueBytesStoreSupplier.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	102
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	74
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedCacheFunction.java	56
streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java	15
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java	146
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java	446
streams/src/main/java/org/apache/kafka/streams/state/internals/StoreSerdeInitializer.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	94
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamsMetadataImpl.java	112
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	308
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java	572
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java	57
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java	118
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSide.java	50
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideDeserializer.java	49
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerde.java	11
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerializer.java	43
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedKeyValueStoreBuilder.java	139
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegment.java	53
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java	42
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java	171
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java	64
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java	13
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java	88
streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueStoreBuilder.java	53
streams/src/main/java/org/apache/kafka/streams/state/internals/VersionedKeyValueToBytesStoreAdapter.java	132
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	188
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	62
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	91
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java	165
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	106
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	46
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java	734
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java	459
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecordingTrigger.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java	456
streams/src/main/java/org/apache/kafka/streams/state/package-info.java	1
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala	101
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala	66
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala	39
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Branched.scala	10
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/BranchedKStream.scala	23
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala	29
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Consumed.scala	33
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Grouped.scala	9
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Joined.scala	16
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala	64
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala	46
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala	164
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala	198
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Materialized.scala	26
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Produced.scala	12
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala	16
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupedKStream.scala	14
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.scala	58
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala	25
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKStream.scala	14
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.scala	53
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala	13
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/package.scala	8
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization/Serdes.scala	65
streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java	115
streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java	91
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java	858
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java	343
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java	346