6,843 results
« Page 50 of 69 »
Detected license expression: apache-2.0
View the resource tree
Packages
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
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java scanned file 47.2 KB RestoreIntegrationTest.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/RocksDBMetricsIntegrationTest.java scanned file 16.6 KB RocksDBMetricsIntegrationTest.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/SelfJoinUpgradeIntegrationTest.java scanned file 10.8 KB SelfJoinUpgradeIntegrationTest.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/SlidingWindowedKStreamIntegrationTest.java scanned file 23.2 KB SlidingWindowedKStreamIntegrationTest.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/SmokeTestDriverIntegrationTest.java scanned file 9.1 KB SmokeTestDriverIntegrationTest.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/StandbyTaskCreationIntegrationTest.java scanned file 8.6 KB StandbyTaskCreationIntegrationTest.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/StandbyTaskEOSIntegrationTest.java scanned file 15.7 KB StandbyTaskEOSIntegrationTest.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/StandbyTaskEOSMultiRebalanceIntegrationTest.java scanned file 13.7 KB StandbyTaskEOSMultiRebalanceIntegrationTest.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/StateDirectoryIntegrationTest.java scanned file 11.8 KB StateDirectoryIntegrationTest.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/StateUpdaterFailureIntegrationTest.java scanned file 7.5 KB StateUpdaterFailureIntegrationTest.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/StoreQueryIntegrationTest.java scanned file 32.7 KB StoreQueryIntegrationTest.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/StoreQuerySuite.java scanned file 2.0 KB StoreQuerySuite.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/StoreUpgradeIntegrationTest.java scanned file 46.9 KB StoreUpgradeIntegrationTest.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/StreamStreamJoinIntegrationTest.java scanned file 24.5 KB StreamStreamJoinIntegrationTest.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/StreamsUncaughtExceptionHandlerIntegrationTest.java scanned file 17.7 KB StreamsUncaughtExceptionHandlerIntegrationTest.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/StreamsUpgradeTestIntegrationTest.java scanned file 5.5 KB StreamsUpgradeTestIntegrationTest.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/StreamTableJoinIntegrationTest.java scanned file 8.0 KB StreamTableJoinIntegrationTest.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/StreamTableJoinTopologyOptimizationIntegrationTest.java scanned file 10.7 KB StreamTableJoinTopologyOptimizationIntegrationTest.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/StreamTableJoinWithGraceIntegrationTest.java scanned file 5.4 KB StreamTableJoinWithGraceIntegrationTest.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/SuppressionDurabilityIntegrationTest.java scanned file 13.7 KB SuppressionDurabilityIntegrationTest.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/SuppressionIntegrationTest.java scanned file 23.8 KB SuppressionIntegrationTest.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/SwallowUnknownTopicErrorIntegrationTest.java scanned file 7.6 KB SwallowUnknownTopicErrorIntegrationTest.java .java Java text/x-java apache-2.0