[
https://issues.apache.org/jira/browse/KAFKA-10131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar updated KAFKA-10131:
-----------------------------------
Description:
Get the ducktape tests working without the --zookeeper flag (except for scram).
(Note: When doing compat testing we'll still use the old flags.)
Below are the current usages (-changes for reassign_partitions)
{code:java}
./kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py: # Cannot use
--zookeeper because kafka-topics.sh is unable to connect to a TLS-enabled
ZooKeeper quorum,
./kafkatest/tests/client/quota_test.py: cmd = "%s --zookeeper %s --alter
--add-config producer_byte_rate=%d,consumer_byte_rate=%d" % \
./kafkatest/services/console_consumer.py: cmd += " --zookeeper
%(zk_connect)s" % args
./kafkatest/services/security/security_config.py: cmd = "%s
--zookeeper %s --entity-name %s --entity-type users --alter --add-config
%s=[password=%s]" % \
Binary file ./kafkatest/services/console_consumer.pyc matches
./kafkatest/services/zookeeper.py: la_migra_cmd += "%s
--zookeeper.acl=%s --zookeeper.connect=%s %s" % \
./kafkatest/services/zookeeper.py: cmd = "%s kafka.admin.ConfigCommand
--zookeeper %s %s --describe --topic %s" % \
./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
--entity-name %s --entity-type topics --alter --add-config
message.format.version=%s" % \
./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
--entity-name %s --entity-type topics --alter --add-config
unclean.leader.election.enable=%s" % \
./kafkatest/services/kafka/kafka.py: return "--zookeeper %s " %
self.zk_connect_setting()
./kafkatest/services/kafka/kafka.py: connection_setting =
"--zookeeper %s" % (self.zk_connect_setting())
09:48:31 [tests]$
{code}
was:
Get the ducktape tests working without the --zookeeper flag (except for scram).
(Note: When doing compat testing we'll still use the old flags.)
Below are the current usages
{code:java}
./kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py: # Cannot use
--zookeeper because kafka-topics.sh is unable to connect to a TLS-enabled
ZooKeeper quorum,
./kafkatest/tests/client/quota_test.py: cmd = "%s --zookeeper %s --alter
--add-config producer_byte_rate=%d,consumer_byte_rate=%d" % \
./kafkatest/services/console_consumer.py: cmd += " --zookeeper
%(zk_connect)s" % args
./kafkatest/services/security/security_config.py: cmd = "%s
--zookeeper %s --entity-name %s --entity-type users --alter --add-config
%s=[password=%s]" % \
Binary file ./kafkatest/services/console_consumer.pyc matches
./kafkatest/services/zookeeper.py: la_migra_cmd += "%s
--zookeeper.acl=%s --zookeeper.connect=%s %s" % \
./kafkatest/services/zookeeper.py: cmd = "%s kafka.admin.ConfigCommand
--zookeeper %s %s --describe --topic %s" % \
./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
--entity-name %s --entity-type topics --alter --add-config
message.format.version=%s" % \
./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
--entity-name %s --entity-type topics --alter --add-config
unclean.leader.election.enable=%s" % \
./kafkatest/services/kafka/kafka.py: return "--zookeeper %s " %
self.zk_connect_setting()
./kafkatest/services/kafka/kafka.py: connection_setting =
"--zookeeper %s" % (self.zk_connect_setting())
09:48:31 [tests]$
{code}
> Minimize use of --zookeeper flag in ducktape tests
> --------------------------------------------------
>
> Key: KAFKA-10131
> URL: https://issues.apache.org/jira/browse/KAFKA-10131
> Project: Kafka
> Issue Type: Improvement
> Components: system tests
> Reporter: Vinoth Chandar
> Assignee: Vinoth Chandar
> Priority: Major
>
> Get the ducktape tests working without the --zookeeper flag (except for
> scram).
> (Note: When doing compat testing we'll still use the old flags.)
> Below are the current usages (-changes for reassign_partitions)
> {code:java}
> ./kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py: # Cannot
> use --zookeeper because kafka-topics.sh is unable to connect to a TLS-enabled
> ZooKeeper quorum,
> ./kafkatest/tests/client/quota_test.py: cmd = "%s --zookeeper %s
> --alter --add-config producer_byte_rate=%d,consumer_byte_rate=%d" % \
> ./kafkatest/services/console_consumer.py: cmd += " --zookeeper
> %(zk_connect)s" % args
> ./kafkatest/services/security/security_config.py: cmd = "%s
> --zookeeper %s --entity-name %s --entity-type users --alter --add-config
> %s=[password=%s]" % \
> Binary file ./kafkatest/services/console_consumer.pyc matches
> ./kafkatest/services/zookeeper.py: la_migra_cmd += "%s
> --zookeeper.acl=%s --zookeeper.connect=%s %s" % \
> ./kafkatest/services/zookeeper.py: cmd = "%s kafka.admin.ConfigCommand
> --zookeeper %s %s --describe --topic %s" % \
> ./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
> --entity-name %s --entity-type topics --alter --add-config
> message.format.version=%s" % \
> ./kafkatest/services/kafka/kafka.py: cmd += "%s --zookeeper %s %s
> --entity-name %s --entity-type topics --alter --add-config
> unclean.leader.election.enable=%s" % \
> ./kafkatest/services/kafka/kafka.py: return "--zookeeper %s " %
> self.zk_connect_setting()
> ./kafkatest/services/kafka/kafka.py: connection_setting =
> "--zookeeper %s" % (self.zk_connect_setting())
> 09:48:31 [tests]$
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
