|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/security_test.py
|
scanned
|
file
|
8.1 KB
|
security_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/share_consume_bench_test.py
|
scanned
|
file
|
10.8 KB
|
share_consume_bench_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/share_group_command_test.py
|
scanned
|
file
|
5.7 KB
|
share_group_command_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/snapshot_test.py
|
scanned
|
file
|
12.5 KB
|
snapshot_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/throttling_test.py
|
scanned
|
file
|
8.6 KB
|
throttling_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/transactions_mixed_versions_test.py
|
scanned
|
file
|
11.2 KB
|
transactions_mixed_versions_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/transactions_test.py
|
scanned
|
file
|
13.4 KB
|
transactions_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/transactions_upgrade_test.py
|
scanned
|
file
|
13.3 KB
|
transactions_upgrade_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/core/upgrade_test.py
|
scanned
|
file
|
10.4 KB
|
upgrade_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/end_to_end.py
|
scanned
|
file
|
7.0 KB
|
end_to_end.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/__init__.py
|
scanned
|
file
|
780 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/kafka_test.py
|
scanned
|
file
|
1.9 KB
|
kafka_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/produce_consume_validate.py
|
scanned
|
file
|
5.8 KB
|
produce_consume_validate.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/base_streams_test.py
|
scanned
|
file
|
6.3 KB
|
base_streams_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/__init__.py
|
scanned
|
file
|
780 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_application_upgrade_test.py
|
scanned
|
file
|
16.6 KB
|
streams_application_upgrade_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_broker_bounce_test.py
|
scanned
|
file
|
14.1 KB
|
streams_broker_bounce_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_broker_compatibility_test.py
|
scanned
|
file
|
4.5 KB
|
streams_broker_compatibility_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
|
scanned
|
file
|
18.2 KB
|
streams_broker_down_resilience_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_eos_test.py
|
scanned
|
file
|
9.8 KB
|
streams_eos_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py
|
scanned
|
file
|
4.0 KB
|
streams_named_repartition_topic_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_optimized_test.py
|
scanned
|
file
|
7.0 KB
|
streams_optimized_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_relational_smoke_test.py
|
scanned
|
file
|
6.5 KB
|
streams_relational_smoke_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py
|
scanned
|
file
|
1.9 KB
|
streams_shutdown_deadlock_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_smoke_test.py
|
scanned
|
file
|
5.6 KB
|
streams_smoke_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_standby_replica_test.py
|
scanned
|
file
|
10.4 KB
|
streams_standby_replica_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_static_membership_test.py
|
scanned
|
file
|
4.7 KB
|
streams_static_membership_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/streams_upgrade_test.py
|
scanned
|
file
|
29.5 KB
|
streams_upgrade_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/templates/log4j2_template.yaml
|
scanned
|
file
|
1.3 KB
|
log4j2_template.yaml
|
.yaml
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/templates/log4j_template.properties
|
scanned
|
file
|
1.3 KB
|
log4j_template.properties
|
.properties
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/utils/__init__.py
|
scanned
|
file
|
900 bytes
|
__init__.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/streams/utils/util.py
|
scanned
|
file
|
2.0 KB
|
util.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/tools/__init__.py
|
scanned
|
file
|
780 bytes
|
__init__.py
|
.py
|
Python
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/tools/kibosh_test.py
|
scanned
|
file
|
3.6 KB
|
kibosh_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/tools/log_compaction_test.py
|
scanned
|
file
|
3.1 KB
|
log_compaction_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/tools/replica_verification_test.py
|
scanned
|
file
|
4.2 KB
|
replica_verification_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/tools/trogdor_test.py
|
scanned
|
file
|
4.4 KB
|
trogdor_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/verifiable_consumer_test.py
|
scanned
|
file
|
5.1 KB
|
verifiable_consumer_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/tests/verifiable_share_consumer_test.py
|
scanned
|
file
|
5.4 KB
|
verifiable_share_consumer_test.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/kafkatest/utils/__init__.py
|
scanned
|
file
|
895 bytes
|
__init__.py
|
.py
|
Python
|
text/x-script.python
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/MANIFEST.in
|
scanned
|
file
|
823 bytes
|
MANIFEST.in
|
.in
|
|
text/plain
|
|
apache-2.0
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/README.md
|
scanned
|
file
|
14.0 KB
|
README.md
|
.md
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/setup.cfg
|
application-package
|
file
|
1.3 KB
|
setup.cfg
|
.cfg
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/setup.py
|
application-package
|
file
|
2.0 KB
|
setup.py
|
.py
|
Python
|
text/x-script.python
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tests/unit/setup.cfg
|
application-package
|
file
|
1.1 KB
|
setup.cfg
|
.cfg
|
|
text/plain
|
|
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.zip-extract/kafka-4.2.0-src/tools/.gitignore
|
scanned
|
file
|
6 bytes
|
.gitignore
|
|
|
text/plain
|
|
|
|
|
|
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/AdminCommandFailedException.java
|
scanned
|
file
|
1.1 KB
|
AdminCommandFailedException.java
|
.java
|
Java
|
text/plain
|
|
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/AdminOperationException.java
|
scanned
|
file
|
1.1 KB
|
AdminOperationException.java
|
.java
|
Java
|
text/plain
|
|
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/ConsoleConsumerOptions.java
|
scanned
|
file
|
23.6 KB
|
ConsoleConsumerOptions.java
|
.java
|
Java
|
text/x-java
|
|
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/ConsoleShareConsumerOptions.java
|
scanned
|
file
|
17.6 KB
|
ConsoleShareConsumerOptions.java
|
.java
|
Java
|
text/x-java
|
|
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/CoordinatorRecordMessageFormatter.java
|
scanned
|
file
|
3.7 KB
|
CoordinatorRecordMessageFormatter.java
|
.java
|
Java
|
text/x-java
|
|
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/DefaultMessageFormatter.java
|
scanned
|
file
|
9.7 KB
|
DefaultMessageFormatter.java
|
.java
|
Java
|
text/x-java
|
|
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
|
|
|
|
kafka_neu-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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-76e4d1b5-8b7b-4eb8-ad4b-86e90f693c1d.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
|
|
|