5,643 results
« Page 40 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/log/RemoteIndexCacheTest.java scanned file 70.6 KB RemoteIndexCacheTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/log/TimeIndexTest.java scanned file 7.2 KB TimeIndexTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/log/TransactionIndexTest.java scanned file 8.4 KB TransactionIndexTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/log/UnifiedLogTest.java scanned file 1.3 KB UnifiedLogTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/log/VerificationGuardTest.java scanned file 2.4 KB VerificationGuardTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/storage/internals/utils/ThrottlerTest.java scanned file 5.0 KB ThrottlerTest.java .java Java text/x-c++ apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/AlterLogDirAction.java scanned file 4.1 KB AlterLogDirAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/BounceBrokerAction.java scanned file 1.4 KB BounceBrokerAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ConsumeAction.java scanned file 11.0 KB ConsumeAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/CreatePartitionsAction.java scanned file 1.6 KB CreatePartitionsAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/CreateTopicAction.java scanned file 2.0 KB CreateTopicAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/DeleteRecordsAction.java scanned file 3.7 KB DeleteRecordsAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/DeleteTopicAction.java scanned file 4.0 KB DeleteTopicAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/EraseBrokerStorageAction.java scanned file 2.0 KB EraseBrokerStorageAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectBrokerInISRAction.java scanned file 2.4 KB ExpectBrokerInISRAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectEmptyRemoteStorageAction.java scanned file 2.4 KB ExpectEmptyRemoteStorageAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectLeaderAction.java scanned file 5.0 KB ExpectLeaderAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectLeaderEpochCheckpointAction.java scanned file 3.2 KB ExpectLeaderEpochCheckpointAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectListOffsetsAction.java scanned file 2.8 KB ExpectListOffsetsAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectTopicIdToMatchInRemoteStorageAction.java scanned file 2.5 KB ExpectTopicIdToMatchInRemoteStorageAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ExpectUserTopicMappedToMetadataPartitionsAction.java scanned file 3.5 KB ExpectUserTopicMappedToMetadataPartitionsAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ProduceAction.java scanned file 8.5 KB ProduceAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ReassignReplicaAction.java scanned file 3.2 KB ReassignReplicaAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/ShrinkReplicaAction.java scanned file 3.7 KB ShrinkReplicaAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/StartBrokerAction.java scanned file 1.4 KB StartBrokerAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/StopBrokerAction.java scanned file 1.4 KB StopBrokerAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/UpdateBrokerConfigAction.java scanned file 2.1 KB UpdateBrokerConfigAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/actions/UpdateTopicConfigAction.java scanned file 2.1 KB UpdateTopicConfigAction.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/AlterLogDirTest.java scanned file 3.1 KB AlterLogDirTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/BaseDeleteSegmentsTest.java scanned file 3.8 KB BaseDeleteSegmentsTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/BaseReassignReplicaTest.java scanned file 4.5 KB BaseReassignReplicaTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsByRetentionSizeTest.java scanned file 1.1 KB DeleteSegmentsByRetentionSizeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsByRetentionTimeTest.java scanned file 1.1 KB DeleteSegmentsByRetentionTimeTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteSegmentsDueToLogStartOffsetBreachTest.java scanned file 5.0 KB DeleteSegmentsDueToLogStartOffsetBreachTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/DeleteTopicTest.java scanned file 3.5 KB DeleteTopicTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/DisableRemoteLogOnTopicTest.java scanned file 5.9 KB DisableRemoteLogOnTopicTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/EnableRemoteLogOnTopicTest.java scanned file 4.4 KB EnableRemoteLogOnTopicTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/storage/src/test/java/org/apache/kafka/tiered/storage/integration/FetchFromLeaderWithCorruptedCheckpointTest.java scanned file 4.0 KB FetchFromLeaderWithCorruptedCheckpointTest.java .java Java text/x-java apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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