8,627 results
« Page 85 of 87 »
View the resource tree
Packages
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/test/java/org/apache/kafka/tools scanned directory tools
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tools/tools-api/src/test/java/org/apache/kafka/tools/api scanned directory api
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 scanned directory transaction-coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction scanned directory transaction
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/main/resources scanned directory resources
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/resources/common scanned directory common
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/resources/common/message scanned directory message
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/resources/common/message/TransactionLogKey.json scanned file 1.0 KB TransactionLogKey.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/main/resources/common/message/TransactionLogValue.json scanned file 3.0 KB TransactionLogValue.json .json text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test scanned directory test
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction scanned directory transaction
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
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/transaction-coordinator/src/test/java/org/apache/kafka/coordinator/transaction/TransactionStateManagerConfigTest.java scanned file 4.3 KB TransactionStateManagerConfigTest.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor scanned directory trogdor
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/.gitignore scanned file 6 bytes .gitignore text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/README.md scanned file 9.0 KB README.md .md text/plain
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src scanned directory src
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main scanned directory main
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java scanned directory java
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org scanned directory org
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache scanned directory apache
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka scanned directory kafka
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor scanned directory trogdor
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/agent scanned directory agent
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java scanned file 12.3 KB AgentClient.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/agent/Agent.java scanned file 9.7 KB Agent.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/agent/AgentRestResource.java scanned file 3.6 KB AgentRestResource.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java scanned file 24.4 KB WorkerManager.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/basic scanned directory basic
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/basic/BasicNode.java scanned file 3.4 KB BasicNode.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/basic/BasicPlatform.java scanned file 3.9 KB BasicPlatform.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/basic/BasicTopology.java scanned file 1.9 KB BasicTopology.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common scanned directory common
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/JsonUtil.java scanned file 3.7 KB JsonUtil.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/Node.java scanned file 2.0 KB Node.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/Platform.java scanned file 2.7 KB Platform.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/StringExpander.java scanned file 2.1 KB StringExpander.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/StringFormatter.java scanned file 3.9 KB StringFormatter.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/Topology.java scanned file 1.7 KB Topology.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java scanned file 16.6 KB WorkerUtils.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator scanned directory coordinator
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java scanned file 21.4 KB CoordinatorClient.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/Coordinator.java scanned file 6.5 KB Coordinator.java .java Java text/x-c apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorRestResource.java scanned file 5.7 KB CoordinatorRestResource.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java scanned file 13.9 KB NodeManager.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java scanned file 25.6 KB TaskManager.java .java Java text/x-c++ apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault scanned directory fault
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultSpec.java scanned file 3.2 KB DegradedNetworkFaultSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/DegradedNetworkFaultWorker.java scanned file 7.5 KB DegradedNetworkFaultWorker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/FilesUnreadableFaultSpec.java scanned file 2.8 KB FilesUnreadableFaultSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultController.java scanned file 1.2 KB KiboshFaultController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/KiboshFaultWorker.java scanned file 2.5 KB KiboshFaultWorker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/Kibosh.java scanned file 6.5 KB Kibosh.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultController.java scanned file 1.5 KB NetworkPartitionFaultController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultSpec.java scanned file 2.7 KB NetworkPartitionFaultSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/NetworkPartitionFaultWorker.java scanned file 3.4 KB NetworkPartitionFaultWorker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultController.java scanned file 1.3 KB ProcessStopFaultController.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultSpec.java scanned file 2.3 KB ProcessStopFaultSpec.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/fault/ProcessStopFaultWorker.java scanned file 3.5 KB ProcessStopFaultWorker.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest scanned directory rest
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/AgentStatusResponse.java scanned file 1.7 KB AgentStatusResponse.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorShutdownRequest.java scanned file 1.3 KB CoordinatorShutdownRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/CoordinatorStatusResponse.java scanned file 1.3 KB CoordinatorStatusResponse.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/CreateTaskRequest.java scanned file 1.5 KB CreateTaskRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/CreateWorkerRequest.java scanned file 1.7 KB CreateWorkerRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/DestroyTaskRequest.java scanned file 1.3 KB DestroyTaskRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/DestroyWorkerRequest.java scanned file 1.3 KB DestroyWorkerRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/Empty.java scanned file 1.4 KB Empty.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/ErrorResponse.java scanned file 1.5 KB ErrorResponse.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/JsonRestServer.java scanned file 12.3 KB JsonRestServer.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/Message.java scanned file 1.3 KB Message.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/RequestConflictException.java scanned file 1.2 KB RequestConflictException.java .java Java text/plain apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/RestExceptionMapper.java scanned file 3.5 KB RestExceptionMapper.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/StopTaskRequest.java scanned file 1.2 KB StopTaskRequest.java .java Java text/x-java apache-2.0
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/trogdor/src/main/java/org/apache/kafka/trogdor/rest/StopWorkerRequest.java scanned file 1.3 KB StopWorkerRequest.java .java Java text/x-java apache-2.0