Path	Lines of Code
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java	19
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java	158
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java	66
streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java	36
streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java	61
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java	66
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java	103
streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java	110
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/src/main/java/org/apache/kafka/streams/KafkaClientSupplier.java	24
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java	713
streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java	60
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	195
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java	840
streams/src/main/java/org/apache/kafka/streams/StreamsMetrics.java	43
streams/src/main/java/org/apache/kafka/streams/Topology.java	309
streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java	37
streams/src/main/java/org/apache/kafka/streams/errors/BrokerNotFoundException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DefaultProductionExceptionHandler.java	13
streams/src/main/java/org/apache/kafka/streams/errors/DeserializationExceptionHandler.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	11
streams/src/main/java/org/apache/kafka/streams/errors/LockException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/LogAndContinueExceptionHandler.java	22
streams/src/main/java/org/apache/kafka/streams/errors/LogAndFailExceptionHandler.java	22
streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java	7
streams/src/main/java/org/apache/kafka/streams/errors/ProcessorStateException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/ProductionExceptionHandler.java	18
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreMigratedException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/StateStoreNotAvailableException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/StreamsException.java	14
streams/src/main/java/org/apache/kafka/streams/errors/StreamsNotStartedException.java	12
streams/src/main/java/org/apache/kafka/streams/errors/StreamsRebalancingException.java	10
streams/src/main/java/org/apache/kafka/streams/errors/TaskAssignmentException.java	13
streams/src/main/java/org/apache/kafka/streams/errors/TaskCorruptedException.java	21
streams/src/main/java/org/apache/kafka/streams/errors/TaskIdFormatException.java	13
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	10
streams/src/main/java/org/apache/kafka/streams/internals/ApiUtils.java	34
streams/src/main/java/org/apache/kafka/streams/internals/metrics/ClientMetrics.java	97
streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/CogroupedKStream.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/Consumed.java	90
streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/GlobalKTable.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java	45
streams/src/main/java/org/apache/kafka/streams/kstream/Initializer.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java	131
streams/src/main/java/org/apache/kafka/streams/kstream/Joined.java	73
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java	178
streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java	140
streams/src/main/java/org/apache/kafka/streams/kstream/KeyValueMapper.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java	98
streams/src/main/java/org/apache/kafka/streams/kstream/Merger.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Named.java	47
streams/src/main/java/org/apache/kafka/streams/kstream/NamedOperation.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/Predicate.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Printed.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/Produced.java	83
streams/src/main/java/org/apache/kafka/streams/kstream/Reducer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/Repartitioned.java	62
streams/src/main/java/org/apache/kafka/streams/kstream/Serialized.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedDeserializer.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedSerializer.java	52
streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java	84
streams/src/main/java/org/apache/kafka/streams/kstream/SlidingWindows.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java	163
streams/src/main/java/org/apache/kafka/streams/kstream/Suppressed.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java	20
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedDeserializer.java	64
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java	36
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedSerializer.java	53
streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java	136
streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java	13
streams/src/main/java/org/apache/kafka/streams/kstream/TransformerSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java	82
streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoiner.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java	4
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java	5
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	56
streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java	38
streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java	101
streams/src/main/java/org/apache/kafka/streams/kstream/internals/Change.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedDeserializer.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedKStreamImpl.java	117
streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java	218
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ConsumedInternal.java	41
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	87
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	386
streams/src/main/java/org/apache/kafka/streams/kstream/internals/JoinedInternal.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java	201
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java	181
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	107
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamBranch.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFilter.java	25
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMap.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatMapValues.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransform.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamFlatTransformValues.java	48
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamGlobalKTableJoin.java	24
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java	1159
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java	157
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamJoinWindow.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java	79
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoin.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java	56
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMap.java	23
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamMapValues.java	22
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamPeek.java	26
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	100
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java	181
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java	349
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransformValues.java	43
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java	167
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableAggregate.java	86
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java	947
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableAbstractJoin.java	25
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	123
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java	95
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java	128
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableOuterJoin.java	136
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableRightJoin.java	119
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMaterializedValueGetterSupplier.java	31
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	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java	115
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSourceValueGetterSupplier.java	30
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableTransformValues.java	116
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetter.java	8
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableValueGetterSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/MaterializedInternal.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/PassThrough.java	16
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/SerializedInternal.java	14
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionCacheFlushListener.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionTupleForwarder.java	28
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	115
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java	220
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedCogroupedKStreamImpl.java	113
streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java	190
streams/src/main/java/org/apache/kafka/streams/kstream/internals/StreamJoinedInternal.java	30
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	136
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java	211
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedCacheFlushListener.java	32
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedKeyValueStoreMaterializer.java	33
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarder.java	34
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TransformerSupplierAdapter.java	40
streams/src/main/java/org/apache/kafka/streams/kstream/internals/UnlimitedWindow.java	15
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	16
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WindowingDefaults.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableDeserializer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/WrappingNullableSerializer.java	5
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/CombinedKey.java	31
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/ForeignJoinSubscriptionProcessorSupplier.java	80
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/ForeignJoinSubscriptionSendProcessorSupplier.java	125
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionJoinForeignProcessorSupplier.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResolverJoinProcessorSupplier.java	70
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapper.java	37
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionResponseWrapperSerde.java	99
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionStoreReceiveProcessorSupplier.java	77
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapper.java	67
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java	118
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseJoinProcessorNode.java	54
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/BaseRepartitionNode.java	108
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GlobalStoreNode.java	46
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/GraphGraceSearchUtil.java	65
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	174
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/OptimizableRepartitionNode.java	84
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorGraphNode.java	27
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/ProcessorParameters.java	55
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/StatefulProcessorNode.java	66
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSinkNode.java	44
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamSourceNode.java	67
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java	128
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamTableJoinNode.java	35
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamToTableNode.java	39
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamsGraphNode.java	99
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableProcessorNode.java	50
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java	132
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/UnoptimizableRepartitionNode.java	75
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferConfigInternal.java	28
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/BufferFullStrategy.java	6
streams/src/main/java/org/apache/kafka/streams/kstream/internals/suppress/EagerBufferConfigImpl.java	78
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	172
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	94
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	45
streams/src/main/java/org/apache/kafka/streams/processor/AbstractProcessor.java	16
streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java	10
streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java	5
streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java	14
streams/src/main/java/org/apache/kafka/streams/processor/DefaultPartitionGrouper.java	51
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/PartitionGrouper.java	9
streams/src/main/java/org/apache/kafka/streams/processor/Processor.java	7
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorSupplier.java	5
streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java	6
streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java	5
streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java	9
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java	4
streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreListener.java	15
streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java	10
streams/src/main/java/org/apache/kafka/streams/processor/StreamPartitioner.java	6
streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java	66
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java	44
streams/src/main/java/org/apache/kafka/streams/processor/ThreadMetadata.java	99
streams/src/main/java/org/apache/kafka/streams/processor/TimestampExtractor.java	6
streams/src/main/java/org/apache/kafka/streams/processor/To.java	44
streams/src/main/java/org/apache/kafka/streams/processor/TopicNameExtractor.java	4
streams/src/main/java/org/apache/kafka/streams/processor/UsePartitionTimeOnInvalidTimestamp.java	16
streams/src/main/java/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.java	18
streams/src/main/java/org/apache/kafka/streams/processor/WallclockTimestampExtractor.java	8
streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java	10
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java	168
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java	227
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java	225
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java	90
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java	248
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java	115
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java	38
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java	123
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java	93
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java	11
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	367
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java	105
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java	295
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalApiProcessorContext.java	36
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java	40
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java	65
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java	207
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	1614
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java	149
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorAdapter.java	37
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextAdapter.java	177
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java	257
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextReverseAdapter.java	188
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java	156
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	174
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java	478
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java	182
streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java	38
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/RecordBatchingStateRestoreCallback.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java	33
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java	218
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java	75
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java	121
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java	57
streams/src/main/java/org/apache/kafka/streams/processor/internals/RestoringTasks.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java	68
streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java	70
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	30
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java	210
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java	126
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java	280
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java	22
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java	105
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java	31
streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java	32
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java	610
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java	774
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java	725
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java	291
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java	1166
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java	229
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java	71
streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java	83
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java	5
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java	917
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	19
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java	49
streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java	66
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java	407
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java	315
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java	12
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java	310
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/CopartitionedTopicsEnforcer.java	135
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java	20
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java	205
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java	265
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java	7
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java	250
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignor.java	11
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java	174
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java	420
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java	789
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java	282
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java	330
streams/src/main/java/org/apache/kafka/streams/state/HostInfo.java	63
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	10
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreType.java	9
streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java	102
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java	14
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java	6
streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyWindowStore.java	25
streams/src/main/java/org/apache/kafka/streams/state/RocksDBConfigSetter.java	12
streams/src/main/java/org/apache/kafka/streams/state/SessionBytesStoreSupplier.java	6
streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java	11
streams/src/main/java/org/apache/kafka/streams/state/StateSerdes.java	92
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	216
streams/src/main/java/org/apache/kafka/streams/state/StreamsMetadata.java	80
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	46
streams/src/main/java/org/apache/kafka/streams/state/WindowBytesStoreSupplier.java	10
streams/src/main/java/org/apache/kafka/streams/state/WindowStore.java	84
streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractMergedSortedCacheStoreIterator.java	135
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java	259
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractSegments.java	187
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	4
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	6
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java	287
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java	310
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	86
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedKeyValueBytesStore.java	19
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingTimestampedWindowBytesStore.java	20
streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java	106
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	119
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlySessionStore.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/CompositeReadOnlyWindowStore.java	190
streams/src/main/java/org/apache/kafka/streams/state/internals/ContextualRecord.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/DelegatingPeekingKeyValueIterator.java	57
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/InMemoryKeyValueStore.java	149
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	307
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java	421
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowBytesStoreSupplier.java	65
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java	483
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	45
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueSegments.java	34
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueStoreBuilder.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueByteStoreAdapter.java	94
streams/src/main/java/org/apache/kafka/streams/state/internals/KeyValueToTimestampedKeyValueIteratorAdapter.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/LRUCacheEntry.java	60
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	122
streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java	81
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	39
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIterator.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreKeyValueIterator.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java	239
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java	225
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java	76
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStore.java	36
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java	231
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStoreIterator.java	48
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowedKeyValueIterator.java	54
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	297
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	132
streams/src/main/java/org/apache/kafka/streams/state/internals/OrderedBytes.java	32
streams/src/main/java/org/apache/kafka/streams/state/internals/PeekingKeyValueIterator.java	6
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java	47
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyKeyValueStoreFacade.java	37
streams/src/main/java/org/apache/kafka/streams/state/internals/ReadOnlyWindowStoreFacade.java	109
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	37
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java	1111
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBRangeIterator.java	55
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	56
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java	487
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	358
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimestampedWindowStore.java	9
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java	98
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbIterator.java	60
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java	27
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbSessionBytesStoreSupplier.java	39
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbWindowBytesStoreSupplier.java	89
streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java	7
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java	82
streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentedBytesStore.java	28
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	123
streams/src/main/java/org/apache/kafka/streams/state/internals/SessionStoreBuilder.java	41
streams/src/main/java/org/apache/kafka/streams/state/internals/StateStoreProvider.java	8
streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java	98
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java	259
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBuffer.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java	118
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	45
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedSegments.java	34
streams/src/main/java/org/apache/kafka/streams/state/internals/TimestampedWindowStoreBuilder.java	169
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampDeserializer.java	54
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerde.java	35
streams/src/main/java/org/apache/kafka/streams/state/internals/ValueAndTimestampSerializer.java	85
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java	181
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreBuilder.java	51
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowStoreIteratorWrapper.java	73
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowToTimestampedWindowByteStoreAdapter.java	151
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedSessionStoreIterator.java	28
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappedStateStore.java	68
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java	31
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/NamedCacheMetrics.java	67
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	422
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	532
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionConversions.scala	52
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/FunctionsCompatConversions.scala	89
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/ImplicitConversions.scala	60
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala	52
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/StreamsBuilder.scala	48
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/CogroupedKStream.scala	16
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Consumed.scala	20
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	14
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedStream.scala	42
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KGroupedTable.scala	24
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala	132
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala	76
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Materialized.scala	23
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Produced.scala	11
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Repartitioned.scala	15
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedCogroupedKStream.scala	10
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/SessionWindowedKStream.scala	35
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/StreamJoined.scala	23
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Suppressed.scala	28
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedCogroupedKStream.scala	10
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/TimeWindowedKStream.scala	32
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/package.scala	11
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	63
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	762
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java	61
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java	71
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java	335
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java	23