Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-6981

[PROD] Streams 3.1.0 CR1 is missing JsonTemplateLayout plugin for Kafka 4.0.0

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Major Major
    • 3.1.0.GA
    • None
    • None
    • None
    • False
    • Hide

      None

      Show
      None
    • False

      It seems that Kafka 4.0.0 is missing JsonTemplateLayout plugin, as our tests are failing:

      2025-11-19T05:17:05.863862792Z main ERROR Unable to locate plugin type for JsonTemplateLayout
      2025-11-19T05:17:05.897681972Z main ERROR Unable to locate plugin for JsonTemplateLayout
      2025-11-19T05:17:05.899967660Z main ERROR Could not create plugin of type class org.apache.logging.log4j.core.appender.ConsoleAppender for element Console: java.lang.NullPointerException: Cannot invoke "org.apache.logging.log4j.core.config.plugins.util.PluginType.getElementName()" because "childType" is null java.lang.NullPointerException: Cannot invoke "org.apache.logging.log4j.core.config.plugins.util.PluginType.getElementName()" because "childType" is null
      	at org.apache.logging.log4j.core.config.plugins.visitors.PluginElementVisitor.visit(PluginElementVisitor.java:50)
      	at org.apache.logging.log4j.core.config.plugins.util.PluginBuilder.injectFields(PluginBuilder.java:195)
      	at org.apache.logging.log4j.core.config.plugins.util.PluginBuilder.build(PluginBuilder.java:123)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.createPluginObject(AbstractConfiguration.java:1180)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.createConfiguration(AbstractConfiguration.java:1099)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.createConfiguration(AbstractConfiguration.java:1091)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.doConfigure(AbstractConfiguration.java:695)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.initialize(AbstractConfiguration.java:270)
      	at org.apache.logging.log4j.core.config.AbstractConfiguration.start(AbstractConfiguration.java:319)
      	at org.apache.logging.log4j.core.LoggerContext.setConfiguration(LoggerContext.java:673)
      	at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:762)
      	at org.apache.logging.log4j.core.LoggerContext.reconfigure(LoggerContext.java:784)
      	at org.apache.logging.log4j.core.LoggerContext.start(LoggerContext.java:300)
      	at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:153)
      	at org.apache.logging.log4j.core.impl.Log4jContextFactory.getContext(Log4jContextFactory.java:46)
      	at org.apache.logging.log4j.LogManager.getContext(LogManager.java:138)
      	at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getContext(AbstractLoggerAdapter.java:136)
      	at org.apache.logging.slf4j.Log4jLoggerFactory.getContext(Log4jLoggerFactory.java:58)
      	at org.apache.logging.log4j.spi.AbstractLoggerAdapter.getLogger(AbstractLoggerAdapter.java:46)
      	at org.apache.logging.slf4j.Log4jLoggerFactory.getLogger(Log4jLoggerFactory.java:32)
      	at org.slf4j.LoggerFactory.getLogger(LoggerFactory.java:363)
      	at com.typesafe.scalalogging.Logger$.apply(Logger.scala:31)
      	at kafka.utils.Log4jControllerRegistration$.<clinit>(Logging.scala:25)
      	at kafka.tools.StorageTool$.<clinit>(StorageTool.scala:40)
      	at kafka.tools.StorageTool.main(StorageTool.scala) 

              Unassigned Unassigned
              lkral Lukas Kral
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated: