6,866 results
« Page 55 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java scanned file 25.3 KB GlobalStateManagerImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManager.java scanned file 1.3 KB GlobalStateManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java scanned file 7.2 KB GlobalStateUpdateTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java scanned file 20.4 KB GlobalStreamThread.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java scanned file 4.7 KB InternalProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalResourcesNaming.java scanned file 2.3 KB InternalResourcesNaming.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicConfig.java scanned file 4.1 KB InternalTopicConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java scanned file 47.9 KB InternalTopicManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicProperties.java scanned file 1.5 KB InternalTopicProperties.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java scanned file 99.1 KB InternalTopologyBuilder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java scanned file 11.0 KB ProcessorNodeMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/RebalanceListenerMetrics.java scanned file 4.3 KB RebalanceListenerMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java scanned file 45.4 KB StreamsMetricsImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java scanned file 17.7 KB TaskMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java scanned file 18.2 KB ThreadMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TopicMetrics.java scanned file 4.3 KB TopicMetrics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/AddNamedTopologyResult.java scanned file 2.3 KB AddNamedTopologyResult.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java scanned file 21.1 KB KafkaStreamsNamedTopologyWrapper.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyBuilder.java scanned file 1.8 KB NamedTopologyBuilder.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopology.java scanned file 1.8 KB NamedTopology.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStoreQueryParameters.java scanned file 3.4 KB NamedTopologyStoreQueryParameters.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/RemoveNamedTopologyResult.java scanned file 4.7 KB RemoveNamedTopologyResult.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/NoOpProcessorWrapper.java scanned file 3.4 KB NoOpProcessorWrapper.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGrouper.java scanned file 5.8 KB PartitionGrouper.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java scanned file 17.9 KB PartitionGroup.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessingThread.java scanned file 1.2 KB ProcessingThread.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java scanned file 16.2 KB ProcessorContextImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java scanned file 3.6 KB ProcessorContextUtils.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorMetadata.java scanned file 5.0 KB ProcessorMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java scanned file 13.1 KB ProcessorNode.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNodePunctuator.java scanned file 1.1 KB ProcessorNodePunctuator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorRecordContext.java scanned file 8.6 KB ProcessorRecordContext.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java scanned file 34.9 KB ProcessorStateManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java scanned file 10.2 KB ProcessorTopology.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationQueue.java scanned file 2.9 KB PunctuationQueue.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/PunctuationSchedule.java scanned file 3.9 KB PunctuationSchedule.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/QuickUnion.java scanned file 2.1 KB QuickUnion.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java scanned file 7.5 KB ReadOnlyTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordBatchingStateRestoreCallback.java scanned file 1.4 KB RecordBatchingStateRestoreCallback.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java scanned file 29.6 KB RecordCollectorImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollector.java scanned file 3.5 KB RecordCollector.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordDeserializer.java scanned file 7.6 KB RecordDeserializer.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java scanned file 9.2 KB RecordQueue.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopicConfig.java scanned file 3.9 KB RepartitionTopicConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java scanned file 15.6 KB RepartitionTopics.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/SerdeGetter.java scanned file 1.7 KB SerdeGetter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java scanned file 4.7 KB SinkNode.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java scanned file 4.5 KB SourceNode.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/Stamped.java scanned file 1.7 KB Stamped.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java scanned file 2.5 KB StampedRecord.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java scanned file 7.1 KB StandbyTaskCreator.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java scanned file 13.1 KB StandbyTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java scanned file 30.2 KB StateDirectory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManager.java scanned file 2.2 KB StateManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java scanned file 9.1 KB StateManagerUtil.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateRestoreCallbackAdapter.java scanned file 2.3 KB StateRestoreCallbackAdapter.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java scanned file 8.6 KB StateUpdater.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StaticTopicNameExtractor.java scanned file 2.0 KB StaticTopicNameExtractor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreBuilderWrapper.java scanned file 4.6 KB StoreBuilderWrapper.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java scanned file 56.8 KB StoreChangelogReader.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreDelegatingProcessorSupplier.java scanned file 1.7 KB StoreDelegatingProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreFactory.java scanned file 4.8 KB StoreFactory.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java scanned file 28.6 KB StreamsMetadataState.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java scanned file 87.0 KB StreamsPartitionAssignor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java scanned file 14.9 KB StreamsProducer.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java scanned file 5.9 KB StreamsRebalanceListener.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java scanned file 62.4 KB StreamTask.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java scanned file 97.9 KB StreamThread.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThreadTotalBlockedTime.java scanned file 2.4 KB StreamThreadTotalBlockedTime.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/SynchronizedPartitionGroup.java scanned file 3.3 KB SynchronizedPartitionGroup.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAction.java scanned file 944 bytes TaskAction.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskAndAction.java scanned file 2.9 KB TaskAndAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutionMetadata.java scanned file 8.5 KB TaskExecutionMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java scanned file 13.2 KB TaskExecutor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java scanned file 8.6 KB Task.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java scanned file 103.2 KB TaskManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskMetadataImpl.java scanned file 3.4 KB TaskMetadataImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java scanned file 12.6 KB DefaultTaskExecutor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskManager.java scanned file 14.8 KB DefaultTaskManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java scanned file 14.3 KB Tasks.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TasksRegistry.java scanned file 2.8 KB TasksRegistry.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskExecutorCreator.java scanned file 1.1 KB TaskExecutorCreator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskExecutor.java scanned file 3.6 KB TaskExecutor.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/TaskManager.java scanned file 5.5 KB TaskManager.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadMetadataImpl.java scanned file 5.0 KB ThreadMetadataImpl.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ThreadStateTransitionValidator.java scanned file 1.0 KB ThreadStateTransitionValidator.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ToInternal.java scanned file 1.3 KB ToInternal.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TopicPartitionMetadata.java scanned file 4.1 KB TopicPartitionMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java scanned file 28.8 KB TopologyMetadata.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedUnversionedChangelogTopicConfig.java scanned file 3.6 KB UnwindowedUnversionedChangelogTopicConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/VersionedChangelogTopicConfig.java scanned file 4.9 KB VersionedChangelogTopicConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/WindowedChangelogTopicConfig.java scanned file 4.2 KB WindowedChangelogTopicConfig.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/LogAndSkipOnInvalidTimestamp.java scanned file 3.3 KB LogAndSkipOnInvalidTimestamp.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/package-info.java scanned file 1.0 KB package-info.java .java Java text/plain apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java scanned file 17.4 KB ProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/PunctuationType.java scanned file 1.7 KB PunctuationType.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/Punctuator.java scanned file 2.1 KB Punctuator.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/RecordContext.java scanned file 6.5 KB RecordContext.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/StandbyUpdateListener.java scanned file 4.3 KB StandbyUpdateListener.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/StateRestoreCallback.java scanned file 1.1 KB StateRestoreCallback.java .java Java text/plain apache-2.0