5,643 results
« Page 55 of 57 »
Programming language: Java
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommandOptions.java scanned file 18.8 KB StreamsGroupCommandOptions.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/TerseException.java scanned file 1.2 KB TerseException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/ToolsUtils.java scanned file 5.6 KB ToolsUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/TopicCommand.java scanned file 48.4 KB TopicCommand.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java scanned file 18.8 KB TransactionalMessageCopier.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java scanned file 40.5 KB TransactionsCommand.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java scanned file 26.4 KB VerifiableConsumer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java scanned file 20.3 KB VerifiableProducer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java scanned file 22.4 KB VerifiableShareConsumer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/AbstractResetIntegrationTest.java scanned file 20.1 KB AbstractResetIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/AclCommandTest.java scanned file 29.8 KB AclCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/BrokerApiVersionsCommandTest.java scanned file 5.1 KB BrokerApiVersionsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ClientMetricsCommandTest.java scanned file 16.4 KB ClientMetricsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ClusterToolTest.java scanned file 11.7 KB ClusterToolTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ConfigCommandIntegrationTest.java scanned file 38.3 KB ConfigCommandIntegrationTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ConfigCommandTest.java scanned file 79.5 KB ConfigCommandTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ConnectPluginPathTest.java scanned file 31.5 KB ConnectPluginPathTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ConsoleProducerTest.java scanned file 16.1 KB ConsoleProducerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerOptionsTest.java scanned file 36.2 KB ConsoleConsumerOptionsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerTest.java scanned file 21.2 KB ConsoleConsumerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerOptionsTest.java scanned file 22.8 KB ConsoleShareConsumerOptionsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerTest.java scanned file 7.1 KB ConsoleShareConsumerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/CoordinatorRecordMessageFormatterTest.java scanned file 2.5 KB CoordinatorRecordMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/DefaultMessageFormatterTest.java scanned file 7.9 KB DefaultMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/AuthorizerIntegrationTest.java scanned file 2.4 KB AuthorizerIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTest.java scanned file 1.9 KB ConsumerGroupCommandTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandTestUtils.java scanned file 4.2 KB ConsumerGroupCommandTestUtils.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ConsumerGroupServiceTest.java scanned file 17.6 KB ConsumerGroupServiceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteConsumerGroupsTest.java scanned file 18.6 KB DeleteConsumerGroupsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java scanned file 13.7 KB DeleteOffsetsConsumerGroupCommandIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/DescribeConsumerGroupTest.java scanned file 79.7 KB DescribeConsumerGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ListConsumerGroupTest.java scanned file 30.7 KB ListConsumerGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/GroupMetadataMessageFormatterTest.java scanned file 9.6 KB GroupMetadataMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ResetConsumerGroupOffsetTest.java scanned file 44.3 KB ResetConsumerGroupOffsetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/SaslClientsWithInvalidCredentialsTest.java scanned file 8.0 KB SaslClientsWithInvalidCredentialsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandTest.java scanned file 88.1 KB ShareGroupCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/group/share/ShareGroupStateMessageFormatterTest.java scanned file 10.6 KB ShareGroupStateMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/NoOpMessageFormatterTest.java scanned file 1.6 KB NoOpMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/OffsetMessageFormatterTest.java scanned file 7.1 KB OffsetMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ConsumerPerformanceTest.java scanned file 14.2 KB ConsumerPerformanceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/ShareGroupMessageFormatterTest.java scanned file 11.6 KB ShareGroupMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatterTest.java scanned file 4.8 KB TransactionLogMessageFormatterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/DelegationTokenCommandTest.java scanned file 19.1 KB DelegationTokenCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/DeleteRecordsCommandTest.java scanned file 7.3 KB DeleteRecordsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/EndToEndLatencyTest.java scanned file 14.5 KB EndToEndLatencyTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/FeatureCommandTest.java scanned file 38.7 KB FeatureCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/filter/TopicFilterTest.java scanned file 2.4 KB TopicFilterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/GetOffsetShellParsingTest.java scanned file 14.7 KB GetOffsetShellParsingTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/GetOffsetShellTest.java scanned file 21.1 KB GetOffsetShellTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/GroupsCommandTest.java scanned file 32.8 KB GroupsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/JmxToolTest.java scanned file 15.2 KB JmxToolTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandErrorTest.java scanned file 3.9 KB LeaderElectionCommandErrorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/LeaderElectionCommandTest.java scanned file 17.0 KB LeaderElectionCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/LineMessageReaderTest.java scanned file 16.3 KB LineMessageReaderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/LogDirsCommandTest.java scanned file 12.6 KB LogDirsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandErrorTest.java scanned file 4.0 KB MetadataQuorumCommandErrorTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandTest.java scanned file 9.7 KB MetadataQuorumCommandTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/MetadataQuorumCommandUnitTest.java scanned file 12.1 KB MetadataQuorumCommandUnitTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/other/ReplicationQuotasTestRig.java scanned file 19.6 KB ReplicationQuotasTestRig.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ProducerPerformanceTest.java scanned file 33.8 KB ProducerPerformanceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/PushHttpMetricsReporterTest.java scanned file 12.0 KB PushHttpMetricsReporterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandArgsTest.java scanned file 11.7 KB ReassignPartitionsCommandArgsTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommandTest.java scanned file 47.8 KB ReassignPartitionsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/reassign/ReassignPartitionsUnitTest.java scanned file 43.9 KB ReassignPartitionsUnitTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ReplicaVerificationToolTest.java scanned file 3.3 KB ReplicaVerificationToolTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationTest.java scanned file 21.2 KB ResetIntegrationTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ResetIntegrationWithSslTest.java scanned file 3.0 KB ResetIntegrationWithSslTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ShareConsumerPerformanceTest.java scanned file 10.0 KB ShareConsumerPerformanceTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/DeleteStreamsGroupOffsetTest.java scanned file 20.4 KB DeleteStreamsGroupOffsetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/DeleteStreamsGroupTest.java scanned file 29.7 KB DeleteStreamsGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/DescribeStreamsGroupTest.java scanned file 21.2 KB DescribeStreamsGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/ListStreamsGroupTest.java scanned file 10.8 KB ListStreamsGroupTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/ResetStreamsGroupOffsetTest.java scanned file 37.9 KB ResetStreamsGroupOffsetTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/StreamsResetterTest.java scanned file 14.0 KB StreamsResetterTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandTest.java scanned file 31.9 KB StreamsGroupCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/ToolsTestUtils.java scanned file 10.5 KB ToolsTestUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/TopicCommandTest.java scanned file 80.8 KB TopicCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/TransactionsCommandTest.java scanned file 37.3 KB TransactionsCommandTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/test/java/org/apache/kafka/tools/UserScramCredentialsCommandTest.java scanned file 7.9 KB UserScramCredentialsCommandTest.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/Decoder.java scanned file 990 bytes Decoder.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/DefaultDecoder.java scanned file 1.1 KB DefaultDecoder.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/IntegerDecoder.java scanned file 1.1 KB IntegerDecoder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/LongDecoder.java scanned file 1.1 KB LongDecoder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/package-info.java scanned file 900 bytes package-info.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/RecordReader.java scanned file 2.1 KB RecordReader.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/main/java/org/apache/kafka/tools/api/StringDecoder.java scanned file 1.1 KB StringDecoder.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/test/java/org/apache/kafka/tools/api/RecordReaderTest.java scanned file 1.2 KB RecordReaderTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/AddPartitionsToTxnConfig.java scanned file 3.3 KB AddPartitionsToTxnConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/ProducerIdManager.java scanned file 1.8 KB ProducerIdManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/RPCProducerIdManager.java scanned file 9.3 KB RPCProducerIdManager.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionCoordinatorRecordSerde.java scanned file 1.8 KB TransactionCoordinatorRecordSerde.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionLogConfig.java scanned file 8.7 KB TransactionLogConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionMetadata.java scanned file 31.6 KB TransactionMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionState.java scanned file 6.4 KB TransactionState.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionStateManagerConfig.java scanned file 6.6 KB TransactionStateManagerConfig.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TxnTransitMetadata.java scanned file 1.7 KB TxnTransitMetadata.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/ProducerIdManagerTest.java scanned file 13.2 KB ProducerIdManagerTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionCoordinatorRecordSerdeTest.java scanned file 8.4 KB TransactionCoordinatorRecordSerdeTest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionLogConfigTest.java scanned file 5.3 KB TransactionLogConfigTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionLogTest.java scanned file 12.8 KB TransactionLogTest.java .java Java text/x-c++ apache-2.0