bbejeck commented on PR #17294:
URL: https://github.com/apache/kafka/pull/17294#issuecomment-2379918654

   @ahuang98 I still get the following error
   
   
   ``` RemoteCommandError({'ssh_config': {'host': 'ducker03', 'hostname': 
'ducker03', 'user': 'ducker', 'port': 22, 'password': '', 'identityfile': 
'/home/ducker/.ssh/id_rsa', 'connecttimeout': None}, 'hostname': 'ducker03', 
'ssh_hostname': 'ducker03', 'user': 'ducker', 'externally_routable_ip': 
'ducker03', '_logger': <Logger 
kafkatest.tests.streams.streams_optimized_test.StreamsOptimizedTest.test_upgrade_optimized_topology.metadata_quorum=COMBINED_KRAFT-1
 (DEBUG)>, 'os': 'linux', '_ssh_client': <paramiko.client.SSHClient object at 
0xffff8e783e50>, '_sftp_client': <paramiko.sftp_client.SFTPClient object at 
0xffff8e86ec10>, '_custom_ssh_exception_checks': None}, 
'/opt/kafka-dev/bin/kafka-storage.sh format --ignore-formatted --config 
/mnt/kafka/kafka.properties --cluster-id I2eXt9rvSnyhct8BYmW6-w', 1, 
b'Exception in thread "main" java.lang.IllegalArgumentException: requirement 
failed: If process.roles contains just the \'broker\' role, the node id 2 must 
not be included in the set of v
 oters controller.quorum.voters=Set(2)\n\tat 
scala.Predef$.require(Predef.scala:337)\n\tat 
kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:921)\n\tat 
kafka.server.KafkaConfig.<init>(KafkaConfig.scala:830)\n\tat 
kafka.server.KafkaConfig.<init>(KafkaConfig.scala:185)\n\tat 
kafka.tools.StorageTool$.$anonfun$execute$1(StorageTool.scala:80)\n\tat 
scala.Option.flatMap(Option.scala:283)\n\tat 
kafka.tools.StorageTool$.execute(StorageTool.scala:80)\n\tat 
kafka.tools.StorageTool$.main(StorageTool.scala:47)\n\tat 
kafka.tools.StorageTool.main(StorageTool.scala)\n')
   Traceback (most recent call last):
     File 
"/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 
186, in _do_run
       data = self.run_test()
     File 
"/usr/local/lib/python3.9/dist-packages/ducktape/tests/runner_client.py", line 
246, in run_test
       return self.test_context.function(self.test)
     File "/usr/local/lib/python3.9/dist-packages/ducktape/mark/_mark.py", line 
433, in wrapper
       return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
     File 
"/opt/kafka-dev/tests/kafkatest/tests/streams/streams_optimized_test.py", line 
61, in test_upgrade_optimized_topology
       self.kafka.start()
     File "/opt/kafka-dev/tests/kafkatest/services/kafka/kafka.py", line 675, 
in start
       Service.start(self, **kwargs)
     File 
"/usr/local/lib/python3.9/dist-packages/ducktape/services/service.py", line 
265, in start
       self.start_node(node, **kwargs)
     File "/opt/kafka-dev/tests/kafkatest/services/kafka/kafka.py", line 909, 
in start_node
       node.account.ssh(cmd)
     File 
"/usr/local/lib/python3.9/dist-packages/ducktape/cluster/remoteaccount.py", 
line 35, in wrapper
       return method(self, *args, **kwargs)
     File 
"/usr/local/lib/python3.9/dist-packages/ducktape/cluster/remoteaccount.py", 
line 310, in ssh
       raise RemoteCommandError(self, cmd, exit_status, stderr.read())
   ducktape.cluster.remoteaccount.RemoteCommandError: ducker@ducker03: Command 
'/opt/kafka-dev/bin/kafka-storage.sh format --ignore-formatted --config 
/mnt/kafka/kafka.properties --cluster-id I2eXt9rvSnyhct8BYmW6-w' returned 
non-zero exit status 1. Remote error message: b'Exception in thread "main" 
java.lang.IllegalArgumentException: requirement failed: If process.roles 
contains just the \'broker\' role, the node id 2 must not be included in the 
set of voters controller.quorum.voters=Set(2)\n\tat 
scala.Predef$.require(Predef.scala:337)\n\tat 
kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:921)\n\tat 
kafka.server.KafkaConfig.<init>(KafkaConfig.scala:830)\n\tat 
kafka.server.KafkaConfig.<init>(KafkaConfig.scala:185)\n\tat 
kafka.tools.StorageTool$.$anonfun$execute$1(StorageTool.scala:80)\n\tat 
scala.Option.flatMap(Option.scala:283)\n\tat 
kafka.tools.StorageTool$.execute(StorageTool.scala:80)\n\tat 
kafka.tools.StorageTool$.main(StorageTool.scala:47)\n\tat 
kafka.tools.StorageTool
 .main(StorageTool.scala)\n'
   ```
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to