|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/kafkatest/utils/remote_account.py
|
scanned
|
file
|
2.1 KB
|
remote_account.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/kafkatest/utils/transactions_utils.py
|
scanned
|
file
|
2.3 KB
|
transactions_utils.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/kafkatest/utils/util.py
|
scanned
|
file
|
8.0 KB
|
util.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/kafkatest/version.py
|
scanned
|
file
|
7.7 KB
|
version.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/MANIFEST.in
|
scanned
|
file
|
823 bytes
|
MANIFEST.in
|
.in
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/connection_stress_test.json
|
scanned
|
file
|
1.1 KB
|
connection_stress_test.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/external_command.json
|
scanned
|
file
|
1.3 KB
|
external_command.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/round_trip.json
|
scanned
|
file
|
1.2 KB
|
round_trip.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/share_round_trip.json
|
scanned
|
file
|
1.2 KB
|
share_round_trip.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/simple_consume_bench_spec.json
|
scanned
|
file
|
1.2 KB
|
simple_consume_bench_spec.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/simple_produce_bench.json
|
scanned
|
file
|
1.3 KB
|
simple_produce_bench.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/simple_share_consume_bench_spec.json
|
scanned
|
file
|
1.2 KB
|
simple_share_consume_bench_spec.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/spec/transactional-produce-bench.json
|
scanned
|
file
|
1.4 KB
|
transactional-produce-bench.json
|
.json
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/unit/directory_layout/check_project_paths.py
|
scanned
|
file
|
3.6 KB
|
check_project_paths.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/unit/directory_layout/__init__.py
|
scanned
|
file
|
780 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/unit/__init__.py
|
scanned
|
file
|
780 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/unit/version/check_version.py
|
scanned
|
file
|
1.2 KB
|
check_version.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.zip-extract/kafka-4.2.0-src/tests/unit/version/__init__.py
|
scanned
|
file
|
781 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-1778570057504.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-1778570057504.zip-extract/kafka-4.2.0-src/tools/src/main/java/org/apache/kafka/tools/AdminCommandFailedException.java
|
scanned
|
file
|
1.1 KB
|
AdminCommandFailedException.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/AdminOperationException.java
|
scanned
|
file
|
1.1 KB
|
AdminOperationException.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/BrokerApiVersionsCommand.java
|
scanned
|
file
|
14.4 KB
|
BrokerApiVersionsCommand.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/ClientCompatibilityTest.java
|
scanned
|
file
|
22.7 KB
|
ClientCompatibilityTest.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/ClientMetricsCommand.java
|
scanned
|
file
|
16.7 KB
|
ClientMetricsCommand.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/ClusterTool.java
|
scanned
|
file
|
9.8 KB
|
ClusterTool.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/ConnectPluginPath.java
|
scanned
|
file
|
20.4 KB
|
ConnectPluginPath.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/ConsoleProducer.java
|
scanned
|
file
|
23.6 KB
|
ConsoleProducer.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/consumer/ConsoleConsumer.java
|
scanned
|
file
|
8.2 KB
|
ConsoleConsumer.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/consumer/ConsoleConsumerOptions.java
|
scanned
|
file
|
23.6 KB
|
ConsoleConsumerOptions.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/consumer/ConsoleShareConsumer.java
|
scanned
|
file
|
7.5 KB
|
ConsoleShareConsumer.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/consumer/ConsoleShareConsumerOptions.java
|
scanned
|
file
|
17.6 KB
|
ConsoleShareConsumerOptions.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/consumer/CoordinatorRecordMessageFormatter.java
|
scanned
|
file
|
3.7 KB
|
CoordinatorRecordMessageFormatter.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/consumer/DefaultMessageFormatter.java
|
scanned
|
file
|
9.7 KB
|
DefaultMessageFormatter.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/consumer/group/ConsumerGroupCommand.java
|
scanned
|
file
|
55.5 KB
|
ConsumerGroupCommand.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/consumer/group/ConsumerGroupCommandOptions.java
|
scanned
|
file
|
17.4 KB
|
ConsumerGroupCommandOptions.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/consumer/group/CsvUtils.java
|
scanned
|
file
|
4.3 KB
|
CsvUtils.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/consumer/group/GroupInformation.java
|
scanned
|
file
|
1.1 KB
|
GroupInformation.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/consumer/group/MemberAssignmentState.java
|
scanned
|
file
|
1.3 KB
|
MemberAssignmentState.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/consumer/GroupMetadataMessageFormatter.java
|
scanned
|
file
|
1.9 KB
|
GroupMetadataMessageFormatter.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/consumer/group/PartitionAssignmentState.java
|
scanned
|
file
|
1.3 KB
|
PartitionAssignmentState.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/consumer/group/ShareGroupCommand.java
|
scanned
|
file
|
33.7 KB
|
ShareGroupCommand.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/consumer/group/ShareGroupCommandOptions.java
|
scanned
|
file
|
13.2 KB
|
ShareGroupCommandOptions.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/consumer/group/share/ShareGroupStateMessageFormatter.java
|
scanned
|
file
|
1.8 KB
|
ShareGroupStateMessageFormatter.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/consumer/LoggingMessageFormatter.java
|
scanned
|
file
|
2.2 KB
|
LoggingMessageFormatter.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/consumer/NoOpMessageFormatter.java
|
scanned
|
file
|
1.1 KB
|
NoOpMessageFormatter.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/consumer/OffsetsMessageFormatter.java
|
scanned
|
file
|
2.1 KB
|
OffsetsMessageFormatter.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/ConsumerPerformance.java
|
scanned
|
file
|
22.7 KB
|
ConsumerPerformance.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/consumer/ShareGroupMessageFormatter.java
|
scanned
|
file
|
2.5 KB
|
ShareGroupMessageFormatter.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/consumer/TransactionLogMessageFormatter.java
|
scanned
|
file
|
1.7 KB
|
TransactionLogMessageFormatter.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/DelegationTokenCommand.java
|
scanned
|
file
|
15.0 KB
|
DelegationTokenCommand.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/DeleteRecordsCommand.java
|
scanned
|
file
|
8.2 KB
|
DeleteRecordsCommand.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/EndToEndLatency.java
|
scanned
|
file
|
22.6 KB
|
EndToEndLatency.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/FeatureCommand.java
|
scanned
|
file
|
22.8 KB
|
FeatureCommand.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/filter/PartitionFilter.java
|
scanned
|
file
|
2.2 KB
|
PartitionFilter.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/filter/TopicFilter.java
|
scanned
|
file
|
2.4 KB
|
TopicFilter.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/filter/TopicPartitionFilter.java
|
scanned
|
file
|
2.7 KB
|
TopicPartitionFilter.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/GetOffsetShell.java
|
scanned
|
file
|
18.1 KB
|
GetOffsetShell.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/GroupsCommand.java
|
scanned
|
file
|
12.1 KB
|
GroupsCommand.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/JmxTool.java
|
scanned
|
file
|
19.4 KB
|
JmxTool.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/LeaderElectionCommand.java
|
scanned
|
file
|
18.2 KB
|
LeaderElectionCommand.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/LineMessageReader.java
|
scanned
|
file
|
9.8 KB
|
LineMessageReader.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/LogCompactionTester.java
|
scanned
|
file
|
22.5 KB
|
LogCompactionTester.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/LogDirsCommand.java
|
scanned
|
file
|
10.2 KB
|
LogDirsCommand.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/ManifestWorkspace.java
|
scanned
|
file
|
24.5 KB
|
ManifestWorkspace.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/MetadataQuorumCommand.java
|
scanned
|
file
|
23.2 KB
|
MetadataQuorumCommand.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/OAuthCompatibilityTool.java
|
scanned
|
file
|
20.6 KB
|
OAuthCompatibilityTool.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/OffsetsUtils.java
|
scanned
|
file
|
25.5 KB
|
OffsetsUtils.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/PrintVersionAndExitAction.java
|
scanned
|
file
|
1.7 KB
|
PrintVersionAndExitAction.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/ProducerPerformance.java
|
scanned
|
file
|
29.8 KB
|
ProducerPerformance.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/PushHttpMetricsReporter.java
|
scanned
|
file
|
11.4 KB
|
PushHttpMetricsReporter.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/reassign/ActiveMoveState.java
|
scanned
|
file
|
1.3 KB
|
ActiveMoveState.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/reassign/CancelledMoveState.java
|
scanned
|
file
|
1.2 KB
|
CancelledMoveState.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/reassign/CompletedMoveState.java
|
scanned
|
file
|
1.1 KB
|
CompletedMoveState.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/reassign/LogDirMoveState.java
|
scanned
|
file
|
1014 bytes
|
LogDirMoveState.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/reassign/MissingLogDirMoveState.java
|
scanned
|
file
|
1.1 KB
|
MissingLogDirMoveState.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/reassign/MissingReplicaMoveState.java
|
scanned
|
file
|
1.1 KB
|
MissingReplicaMoveState.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/reassign/PartitionMove.java
|
scanned
|
file
|
1.7 KB
|
PartitionMove.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/reassign/PartitionReassignmentState.java
|
scanned
|
file
|
1.2 KB
|
PartitionReassignmentState.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/reassign/ReassignPartitionsCommand.java
|
scanned
|
file
|
81.9 KB
|
ReassignPartitionsCommand.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/reassign/ReassignPartitionsCommandOptions.java
|
scanned
|
file
|
7.3 KB
|
ReassignPartitionsCommandOptions.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/reassign/VerifyAssignmentResult.java
|
scanned
|
file
|
1.7 KB
|
VerifyAssignmentResult.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/ReplicaVerificationTool.java
|
scanned
|
file
|
33.4 KB
|
ReplicaVerificationTool.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/ShareConsumerPerformance.java
|
scanned
|
file
|
25.6 KB
|
ShareConsumerPerformance.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/StreamsResetter.java
|
scanned
|
file
|
38.4 KB
|
StreamsResetter.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/streams/StreamsGroupCommand.java
|
scanned
|
file
|
56.2 KB
|
StreamsGroupCommand.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/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
|
|
|