Browse Source

KAFKA-10050: kafka_log4j_appender.py fixed for JDK11 (#8731)

kafka_log4j_appender.py was broken on JDK11 by befd80b38.
`fix_opts_for_new_jvm` requires `node.version` to be set, we
add the relevant code to the test.

Reviewers: Ismael Juma <ismael@juma.me.uk>
pull/8749/head
Nikolay 5 years ago committed by GitHub
parent
commit
2951b6dd99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 3
      tests/kafkatest/services/kafka_log4j_appender.py

3
tests/kafkatest/services/kafka_log4j_appender.py

@ -38,6 +38,9 @@ class KafkaLog4jAppender(KafkaPathResolverMixin, BackgroundThreadService): @@ -38,6 +38,9 @@ class KafkaLog4jAppender(KafkaPathResolverMixin, BackgroundThreadService):
self.security_config = SecurityConfig(self.context, security_protocol)
self.stop_timeout_sec = 30
for node in self.nodes:
node.version = kafka.nodes[0].version
def _worker(self, idx, node):
cmd = self.start_cmd(node)
self.logger.debug("VerifiableLog4jAppender %d command: %s" % (idx, cmd))

Loading…
Cancel
Save