6,866 results
« Page 50 of 69 »
Detected license expression: _ANY_
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/ListOffsetsTest.java scanned file 6.8 KB ListOffsetsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndConsumeFromLeaderTest.java scanned file 7.1 KB OffloadAndConsumeFromLeaderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/OffloadAndTxnConsumeFromLeaderTest.java scanned file 5.6 KB OffloadAndTxnConsumeFromLeaderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/PartitionsExpandTest.java scanned file 5.4 KB PartitionsExpandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaExpandTest.java scanned file 1.2 KB ReassignReplicaExpandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaMoveTest.java scanned file 1.1 KB ReassignReplicaMoveTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/ReassignReplicaShrinkTest.java scanned file 5.0 KB ReassignReplicaShrinkTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/RollAndOffloadActiveSegmentTest.java scanned file 3.5 KB RollAndOffloadActiveSegmentTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/TransactionsWithTieredStoreTest.java scanned file 5.7 KB TransactionsWithTieredStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/ConsumableSpec.java scanned file 1.2 KB ConsumableSpec.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/DeletableSpec.java scanned file 1.3 KB DeletableSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/ExpandPartitionCountSpec.java scanned file 1.2 KB ExpandPartitionCountSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/FetchableSpec.java scanned file 1.1 KB FetchableSpec.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/FetchCountAndOp.java scanned file 1.2 KB FetchCountAndOp.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/KeyValueSpec.java scanned file 2.2 KB KeyValueSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/OffloadableSpec.java scanned file 1.3 KB OffloadableSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/OffloadedSegmentSpec.java scanned file 1.8 KB OffloadedSegmentSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/ProducableSpec.java scanned file 2.7 KB ProducableSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteDeleteSegmentSpec.java scanned file 2.1 KB RemoteDeleteSegmentSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteFetchCount.java scanned file 3.5 KB RemoteFetchCount.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/RemoteFetchSpec.java scanned file 1.7 KB RemoteFetchSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/specs/TopicSpec.java scanned file 2.1 KB TopicSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestAction.java scanned file 1.3 KB TieredStorageTestAction.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestBuilder.java scanned file 20.1 KB TieredStorageTestBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestContext.java scanned file 16.1 KB TieredStorageTestContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestHarness.java scanned file 6.8 KB TieredStorageTestHarness.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/TieredStorageTestReport.java scanned file 2.8 KB TieredStorageTestReport.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/utils/BrokerLocalStorage.java scanned file 10.3 KB BrokerLocalStorage.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/utils/DumpLocalTieredStorage.java scanned file 1.3 KB DumpLocalTieredStorage.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/utils/LocalTieredStorageOutput.java scanned file 3.9 KB LocalTieredStorageOutput.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/utils/RecordsKeyValueMatcher.java scanned file 8.6 KB RecordsKeyValueMatcher.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java scanned file 12.2 KB TieredStorageTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/storage/src/test/resources/log4j2.yaml scanned file 1.8 KB log4j2.yaml .yaml text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java scanned file 1.9 KB JsonTimestampExtractor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java scanned file 10.2 KB PageViewTypedDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java scanned file 7.2 KB PageViewUntypedDemo.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java scanned file 3.1 KB PipeDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java scanned file 5.8 KB TemperatureDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java scanned file 5.0 KB WordCountDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java scanned file 6.4 KB WordCountProcessorDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java scanned file 7.3 KB WordCountTransformerDemo.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/docs/DeveloperGuideTesting.java scanned file 7.4 KB DeveloperGuideTesting.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java scanned file 4.9 KB WordCountDemoTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java scanned file 3.3 KB WordCountProcessorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest.java scanned file 4.4 KB WordCountTransformerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java scanned file 14.2 KB AbstractJoinIntegrationTest.java .java Java text/x-Algol68 apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java scanned file 23.9 KB AdjustStreamThreadCountTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/AtLeastOnceDeliveryMessageLossIntegrationTest.java scanned file 10.7 KB AtLeastOnceDeliveryMessageLossIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ConsistencyVectorIntegrationTest.java scanned file 9.3 KB ConsistencyVectorIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/DeadLetterQueueIntegrationTest.java scanned file 25.8 KB DeadLetterQueueIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java scanned file 6.9 KB EmitOnChangeIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java scanned file 70.5 KB EosIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/EOSUncleanShutdownIntegrationTest.java scanned file 7.8 KB EOSUncleanShutdownIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/FineGrainedAutoResetIntegrationTest.java scanned file 21.0 KB FineGrainedAutoResetIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ForeignKeyJoinSuite.java scanned file 2.3 KB ForeignKeyJoinSuite.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java scanned file 21.0 KB GlobalKTableEOSIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalKTableIntegrationTest.java scanned file 17.9 KB GlobalKTableIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalStateReprocessTest.java scanned file 7.7 KB GlobalStateReprocessTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/GlobalThreadShutDownOrderTest.java scanned file 8.9 KB GlobalThreadShutDownOrderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HandlingSourceTopicDeletionIntegrationTest.java scanned file 5.8 KB HandlingSourceTopicDeletionIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/HighAvailabilityTaskAssignorIntegrationTest.java scanned file 16.7 KB HighAvailabilityTaskAssignorIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java scanned file 12.4 KB InternalTopicIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2EndpointToPartitionsIntegrationTest.java scanned file 16.1 KB IQv2EndpointToPartitionsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2IntegrationTest.java scanned file 21.0 KB IQv2IntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2StoreIntegrationTest.java scanned file 82.7 KB IQv2StoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2VersionedStoreIntegrationTest.java scanned file 22.2 KB IQv2VersionedStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinGracePeriodDurabilityIntegrationTest.java scanned file 10.5 KB JoinGracePeriodDurabilityIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinStoreIntegrationTest.java scanned file 8.0 KB JoinStoreIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/JoinWithIncompleteMetadataIntegrationTest.java scanned file 5.5 KB JoinWithIncompleteMetadataIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsCloseOptionsIntegrationTest.java scanned file 8.3 KB KafkaStreamsCloseOptionsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsTelemetryIntegrationTest.java scanned file 37.2 KB KafkaStreamsTelemetryIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KafkaStreamsWrapper.java scanned file 2.4 KB KafkaStreamsWrapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationDedupIntegrationTest.java scanned file 11.7 KB KStreamAggregationDedupIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamAggregationIntegrationTest.java scanned file 60.9 KB KStreamAggregationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamKStreamIntegrationTest.java scanned file 8.4 KB KStreamKStreamIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KStreamRepartitionIntegrationTest.java scanned file 35.8 KB KStreamRepartitionIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableEfficientRangeQueryTest.java scanned file 9.9 KB KTableEfficientRangeQueryTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java scanned file 16.8 KB KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java scanned file 13.7 KB KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinDistributedTest.java scanned file 10.3 KB KTableKTableForeignKeyJoinDistributedTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java scanned file 57.9 KB KTableKTableForeignKeyJoinIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinMaterializationIntegrationTest.java scanned file 7.5 KB KTableKTableForeignKeyJoinMaterializationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/KTableSourceTopicRestartIntegrationTest.java scanned file 10.5 KB KTableSourceTopicRestartIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/LagFetchIntegrationTest.java scanned file 17.9 KB LagFetchIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsIntegrationTest.java scanned file 43.5 KB MetricsIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/MetricsReporterIntegrationTest.java scanned file 5.0 KB MetricsReporterIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java scanned file 42.2 KB NamedTopologyIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java scanned file 10.3 KB OptimizedKTableIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PauseResumeIntegrationTest.java scanned file 18.5 KB PauseResumeIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PositionRestartIntegrationTest.java scanned file 27.0 KB PositionRestartIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java scanned file 32.5 KB ProcessingExceptionHandlerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/PurgeRepartitionTopicIntegrationTest.java scanned file 9.5 KB PurgeRepartitionTopicIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java scanned file 58.1 KB QueryableStateIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RangeQueryIntegrationTest.java scanned file 12.0 KB RangeQueryIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceIntegrationTest.java scanned file 9.9 KB RebalanceIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceProtocolMigrationIntegrationTest.java scanned file 8.9 KB RebalanceProtocolMigrationIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RebalanceTaskClosureIntegrationTest.java scanned file 11.9 KB RebalanceTaskClosureIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java scanned file 26.3 KB RegexSourceIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RelaxedNullKeyRequirementJoinTest.java scanned file 5.6 KB RelaxedNullKeyRequirementJoinTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/ResetPartitionTimeIntegrationTest.java scanned file 8.3 KB ResetPartitionTimeIntegrationTest.java .java Java text/x-Algol68 apache-2.0