6,866 results
« Page 54 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueJoinerWithKey.java scanned file 2.8 KB ValueJoinerWithKey.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapper.java scanned file 2.0 KB ValueMapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueMapperWithKey.java scanned file 2.2 KB ValueMapperWithKey.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformer.java scanned file 5.1 KB ValueTransformer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java scanned file 2.3 KB ValueTransformerSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java scanned file 5.5 KB ValueTransformerWithKey.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java scanned file 2.3 KB ValueTransformerWithKeySupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/Windowed.java scanned file 2.5 KB Windowed.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/WindowedSerdes.java scanned file 4.1 KB WindowedSerdes.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/Window.java scanned file 4.3 KB Window.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java scanned file 3.1 KB Windows.java .java Java text/html apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/LagInfo.java scanned file 3.1 KB LagInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/package-info.java scanned file 920 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualFixedKeyProcessor.java scanned file 1.8 KB ContextualFixedKeyProcessor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ContextualProcessor.java scanned file 1.7 KB ContextualProcessor.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessorContext.java scanned file 4.7 KB FixedKeyProcessorContext.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessor.java scanned file 2.8 KB FixedKeyProcessor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyProcessorSupplier.java scanned file 2.2 KB FixedKeyProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/FixedKeyRecord.java scanned file 5.3 KB FixedKeyRecord.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/InternalFixedKeyRecordFactory.java scanned file 1.4 KB InternalFixedKeyRecordFactory.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/package-info.java scanned file 1.0 KB package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessingContext.java scanned file 12.6 KB ProcessingContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorContext.java scanned file 4.6 KB ProcessorContext.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/Processor.java scanned file 2.8 KB Processor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorSupplier.java scanned file 2.4 KB ProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/ProcessorWrapper.java scanned file 4.5 KB ProcessorWrapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/Record.java scanned file 6.9 KB Record.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/RecordMetadata.java scanned file 3.3 KB RecordMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedFixedKeyProcessorSupplier.java scanned file 1.3 KB WrappedFixedKeyProcessorSupplier.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/api/WrappedProcessorSupplier.java scanned file 1.3 KB WrappedProcessorSupplier.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/ApplicationState.java scanned file 2.5 KB ApplicationState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/AssignmentConfigs.java scanned file 9.1 KB AssignmentConfigs.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/package-info.java scanned file 932 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java scanned file 21.4 KB StickyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/KafkaStreamsAssignment.java scanned file 6.4 KB KafkaStreamsAssignment.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/KafkaStreamsState.java scanned file 4.4 KB KafkaStreamsState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/package-info.java scanned file 964 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/ProcessId.java scanned file 2.0 KB ProcessId.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java scanned file 54.3 KB TaskAssignmentUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignor.java scanned file 5.0 KB TaskAssignor.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskInfo.java scanned file 1.9 KB TaskInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskTopicPartition.java scanned file 2.0 KB TaskTopicPartition.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java scanned file 1.6 KB BatchingStateRestoreCallback.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/Cancellable.java scanned file 1.2 KB Cancellable.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/CommitCallback.java scanned file 1.1 KB CommitCallback.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/ConnectedStoreProvider.java scanned file 4.0 KB ConnectedStoreProvider.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/ExtractRecordMetadataTimestamp.java scanned file 3.5 KB ExtractRecordMetadataTimestamp.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/FailOnInvalidTimestamp.java scanned file 3.5 KB FailOnInvalidTimestamp.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractPartitionGroup.java scanned file 3.8 KB AbstractPartitionGroup.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java scanned file 8.6 KB AbstractProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java scanned file 12.0 KB AbstractReadOnlyDecorator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java scanned file 12.0 KB AbstractReadWriteDecorator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java scanned file 7.9 KB AbstractTask.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java scanned file 11.4 KB ActiveTaskCreator.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java scanned file 22.2 KB AssignmentInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java scanned file 7.8 KB AssignorConfiguration.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorError.java scanned file 2.2 KB AssignorError.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/BalanceSubtopologyGraphConstructor.java scanned file 10.6 KB BalanceSubtopologyGraphConstructor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java scanned file 23.5 KB ClientState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientStateTask.java scanned file 1.5 KB ClientStateTask.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientTagAwareStandbyTaskAssignor.java scanned file 20.7 KB ClientTagAwareStandbyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java scanned file 3.6 KB ConstrainedPrioritySet.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConsumerProtocolUtils.java scanned file 4.7 KB ConsumerProtocolUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/CopartitionedTopicsEnforcer.java scanned file 9.1 KB CopartitionedTopicsEnforcer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultApplicationState.java scanned file 3.9 KB DefaultApplicationState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultKafkaStreamsState.java scanned file 6.5 KB DefaultKafkaStreamsState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultStandbyTaskAssignor.java scanned file 3.3 KB DefaultStandbyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultTaskInfo.java scanned file 2.1 KB DefaultTaskInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/DefaultTaskTopicPartition.java scanned file 3.8 KB DefaultTaskTopicPartition.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java scanned file 2.1 KB FallbackPriorTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java scanned file 20.3 KB Graph.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java scanned file 14.5 KB HighAvailabilityTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignor.java scanned file 15.8 KB LegacyStickyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/LegacyTaskAssignor.java scanned file 1.5 KB LegacyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/MinTrafficGraphConstructor.java scanned file 6.2 KB MinTrafficGraphConstructor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructorFactory.java scanned file 3.1 KB RackAwareGraphConstructorFactory.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareGraphConstructor.java scanned file 6.3 KB RackAwareGraphConstructor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java scanned file 24.1 KB RackAwareTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackUtils.java scanned file 7.7 KB RackUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ReferenceContainer.java scanned file 1.9 KB ReferenceContainer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignmentUtils.java scanned file 3.4 KB StandbyTaskAssignmentUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignorFactory.java scanned file 2.1 KB StandbyTaskAssignorFactory.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignor.java scanned file 2.5 KB StandbyTaskAssignor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java scanned file 1.7 KB StreamsAssignmentProtocolVersions.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java scanned file 16.3 KB SubscriptionInfo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java scanned file 16.6 KB TaskMovement.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogReader.java scanned file 2.5 KB ChangelogReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRecordDeserializationHelper.java scanned file 3.3 KB ChangelogRecordDeserializationHelper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogRegister.java scanned file 1.7 KB ChangelogRegister.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ChangelogTopics.java scanned file 6.6 KB ChangelogTopics.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java scanned file 10.5 KB ClientUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ConfigurableStore.java scanned file 991 bytes ConfigurableStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/CorruptedRecord.java scanned file 1.9 KB CorruptedRecord.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultKafkaClientSupplier.java scanned file 2.4 KB DefaultKafkaClientSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java scanned file 48.4 KB DefaultStateUpdater.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamPartitioner.java scanned file 2.1 KB DefaultStreamPartitioner.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStreamsRebalanceListener.java scanned file 6.3 KB DefaultStreamsRebalanceListener.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java scanned file 4.9 KB ForwardingDisabledProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java scanned file 6.5 KB GlobalProcessorContextImpl.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateMaintainer.java scanned file 1.3 KB GlobalStateMaintainer.java .java Java text/x-java apache-2.0