kafka_log4j_appender.py fixed for JDK11
kafka_log4j_appender.py was broken on JDK11 by
`fix_opts_for_new_jvm` requires `node.version` to be set, we
add the relevant code to the test.
Reviewers: Ismael Juma
@@ -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))
