5,643 results
« Page 52 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/StoresTest.java scanned file 14.6 KB StoresTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/state/StreamsMetadataTest.java scanned file 5.6 KB StreamsMetadataTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/StreamsBuilderTest.java scanned file 139.8 KB StreamsBuilderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java scanned file 86.5 KB StreamsConfigTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/BrokerCompatibilityTest.java scanned file 7.8 KB BrokerCompatibilityTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/EosTestClient.java scanned file 9.5 KB EosTestClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java scanned file 36.1 KB EosTestDriver.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTest.java scanned file 43.6 KB RelationalSmokeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/RelationalSmokeTestTest.java scanned file 5.3 KB RelationalSmokeTestTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/ShutdownDeadlockTest.java scanned file 3.3 KB ShutdownDeadlockTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java scanned file 12.0 KB SmokeTestClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java scanned file 32.8 KB SmokeTestDriver.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java scanned file 5.4 KB SmokeTestUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StaticMemberTestClient.java scanned file 3.5 KB StaticMemberTestClient.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsBrokerDownResilienceTest.java scanned file 6.8 KB StreamsBrokerDownResilienceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsEosTest.java scanned file 3.4 KB StreamsEosTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsNamedRepartitionTest.java scanned file 5.4 KB StreamsNamedRepartitionTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java scanned file 7.1 KB StreamsOptimizedTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.4 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsStandByReplicaTest.java scanned file 7.6 KB StreamsStandByReplicaTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 19.2 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtil.java scanned file 2.4 KB SystemTestUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/tests/SystemTestUtilTest.java scanned file 2.8 KB SystemTestUtilTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/TopologyTestDriverWrapper.java scanned file 2.8 KB TopologyTestDriverWrapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/TopologyTest.java scanned file 120.3 KB TopologyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/TopologyWrapper.java scanned file 1.7 KB TopologyWrapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/utils/TestUtils.java scanned file 11.6 KB TestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/streams/utils/UniqueTopicSerdeScope.java scanned file 5.5 KB UniqueTopicSerdeScope.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/GenericInMemoryKeyValueStore.java scanned file 5.3 KB GenericInMemoryKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/GenericInMemoryTimestampedKeyValueStore.java scanned file 5.9 KB GenericInMemoryTimestampedKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/GlobalStateManagerStub.java scanned file 3.3 KB GlobalStateManagerStub.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java scanned file 19.0 KB InternalMockProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/KeyValueIteratorStub.java scanned file 1.5 KB KeyValueIteratorStub.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockAggregator.java scanned file 1.3 KB MockAggregator.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockApiFixedKeyProcessor.java scanned file 5.8 KB MockApiFixedKeyProcessor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockApiFixedKeyProcessorSupplier.java scanned file 2.8 KB MockApiFixedKeyProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockApiProcessor.java scanned file 6.8 KB MockApiProcessor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockApiProcessorSupplier.java scanned file 2.8 KB MockApiProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockCachedKeyValueStore.java scanned file 1.4 KB MockCachedKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockClientSupplier.java scanned file 4.0 KB MockClientSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockInitializer.java scanned file 1.1 KB MockInitializer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java scanned file 8.5 KB MockInternalProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockInternalTopicManager.java scanned file 3.2 KB MockInternalTopicManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockKeyValueStoreBuilder.java scanned file 1.7 KB MockKeyValueStoreBuilder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockKeyValueStore.java scanned file 4.5 KB MockKeyValueStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockMapper.java scanned file 3.1 KB MockMapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockPredicate.java scanned file 1.2 KB MockPredicate.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockProcessor.java scanned file 3.5 KB MockProcessor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockProcessorNode.java scanned file 2.7 KB MockProcessorNode.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockProcessorSupplier.java scanned file 2.8 KB MockProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockRecordCollector.java scanned file 4.4 KB MockRecordCollector.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockReducer.java scanned file 2.0 KB MockReducer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockRestoreCallback.java scanned file 1.2 KB MockRestoreCallback.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockRestoreConsumer.java scanned file 6.2 KB MockRestoreConsumer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockRocksDbConfigSetter.java scanned file 1.4 KB MockRocksDbConfigSetter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockSourceNode.java scanned file 2.1 KB MockSourceNode.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockStandbyUpdateListener.java scanned file 2.3 KB MockStandbyUpdateListener.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockStateRestoreListener.java scanned file 3.8 KB MockStateRestoreListener.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockTimestampExtractor.java scanned file 1.2 KB MockTimestampExtractor.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/MockValueJoiner.java scanned file 1.1 KB MockValueJoiner.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java scanned file 6.2 KB NoOpProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/NoOpReadOnlyStore.java scanned file 3.2 KB NoOpReadOnlyStore.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/NoopValueTransformer.java scanned file 1.2 KB NoopValueTransformer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/NoopValueTransformerWithKey.java scanned file 1.3 KB NoopValueTransformerWithKey.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/NoOpValueTransformerWithKeySupplier.java scanned file 1.7 KB NoOpValueTransformerWithKeySupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/ReadOnlySessionStoreStub.java scanned file 7.5 KB ReadOnlySessionStoreStub.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/StateStoreProviderStub.java scanned file 3.3 KB StateStoreProviderStub.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java scanned file 14.4 KB StreamsTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java scanned file 20.1 KB MockProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java scanned file 21.7 KB MockProcessorContext.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java scanned file 10.6 KB TestInputTopic.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java scanned file 7.1 KB TestOutputTopic.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/test/package-info.java scanned file 924 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/test/TestRecord.java scanned file 6.9 KB TestRecord.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java scanned file 61.0 KB TopologyTestDriver.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/KeyValueStoreFacadeTest.java scanned file 5.2 KB KeyValueStoreFacadeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/MockProcessorContextTest.java scanned file 19.9 KB MockProcessorContextTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/MockTimeTest.java scanned file 2.0 KB MockTimeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextAPITest.java scanned file 14.7 KB MockProcessorContextAPITest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/test/MockProcessorContextStateStoreTest.java scanned file 9.2 KB MockProcessorContextStateStoreTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/test/TestRecordTest.java scanned file 7.9 KB TestRecordTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/TestTopicsTest.java scanned file 22.1 KB TestTopicsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorSupplier.java scanned file 3.3 KB WindowedWordCountProcessorSupplier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/test/wordcount/WindowedWordCountProcessorTest.java scanned file 8.8 KB WindowedWordCountProcessorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverAtLeastOnceTest.java scanned file 1.1 KB TopologyTestDriverAtLeastOnceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverEosTest.java scanned file 1.1 KB TopologyTestDriverEosTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/TopologyTestDriverTest.java scanned file 77.6 KB TopologyTestDriverTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/test-utils/src/test/java/org/apache/kafka/streams/WindowStoreFacadeTest.java scanned file 3.6 KB WindowStoreFacadeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 3.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 3.5 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 3.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 6.0 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 3.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 6.0 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 3.4 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 6.0 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 3.4 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 6.0 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java scanned file 11.9 KB SmokeTestClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/SmokeTestDriver.java scanned file 27.1 KB SmokeTestDriver.java .java Java text/x-java apache-2.0