127 results
« Page 1 of 2 »
Mime type: text/x-c
View the resource tree
Packages
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMetrics.java scanned file 1.9 KB ConsumerMetrics.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetrics.java scanned file 1.8 KB ProducerMetrics.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryProvider.java scanned file 6.2 KB ClientTelemetryProvider.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/common/metrics/stats/HistogramTest.java scanned file 8.8 KB HistogramTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/clients/src/test/java/org/apache/kafka/test/MetricsBench.java scanned file 2.6 KB MetricsBench.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConfig.java scanned file 3.7 KB MirrorHeartbeatConfig.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java scanned file 5.5 KB ConnectDistributed.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/admin/ConfigCommand.scala scanned file 42.3 KB ConfigCommand.scala .scala Scala text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/docker/KafkaDockerWrapper.scala scanned file 13.5 KB KafkaDockerWrapper.scala .scala Scala text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/server/KafkaConfig.scala scanned file 41.0 KB KafkaConfig.scala .scala Scala text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/tools/DumpLogSegments.scala scanned file 32.1 KB DumpLogSegments.scala .scala Scala text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/main/scala/kafka/tools/StorageTool.scala scanned file 20.4 KB StorageTool.scala .scala Scala text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/core/src/test/java/kafka/security/minikdc/MiniKdc.java scanned file 21.6 KB MiniKdc.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/docs/streams/tutorial.md scanned file 24.6 KB tutorial.md .md text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java scanned file 3.2 KB KafkaConsumerProducerDemo.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java scanned file 5.9 KB KafkaExactlyOnceDemo.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/generator/src/main/java/org/apache/kafka/message/checker/MetadataSchemaCheckerTool.java scanned file 4.9 KB MetadataSchemaCheckerTool.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/generator/src/test/java/org/apache/kafka/message/CodeBufferTest.java scanned file 2.7 KB CodeBufferTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java scanned file 18.3 KB TestPurgatoryPerformance.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/StressTestLog.java scanned file 8.0 KB StressTestLog.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java scanned file 15.5 KB TestLinearWriteSpeed.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/shell/src/main/java/org/apache/kafka/shell/MetadataShell.java scanned file 8.8 KB MetadataShell.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/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/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/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java scanned file 2.9 KB LineSplit.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java scanned file 2.6 KB Pipe.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java scanned file 3.5 KB WordCount.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-22/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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-22/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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-23/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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeToCooperativeRebalanceTest.java scanned file 5.7 KB StreamsUpgradeToCooperativeRebalanceTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.8 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.7 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-41/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java scanned file 4.0 KB StreamsSmokeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/streams/upgrade-system-tests-41/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java scanned file 4.9 KB StreamsUpgradeTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/AclCommand.java scanned file 34.4 KB AclCommand.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/BrokerApiVersionsCommand.java scanned file 14.4 KB BrokerApiVersionsCommand.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java scanned file 22.7 KB ClientCompatibilityTest.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java scanned file 16.7 KB ClientMetricsCommand.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ClusterTool.java scanned file 9.8 KB ClusterTool.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java scanned file 20.4 KB ConnectPluginPath.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java scanned file 23.6 KB ConsoleProducer.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleConsumer.java scanned file 8.2 KB ConsoleConsumer.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleShareConsumer.java scanned file 7.5 KB ConsoleShareConsumer.java .java Java text/x-c apache-2.0
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java scanned file 55.5 KB ConsumerGroupCommand.java .java Java text/x-c apache-2.0