Uploaded image for project: 'jBPM'
  1. jBPM
  2. JBPM-9346

Exception when deploying WIH Kafka in wildfly/EAP

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved (View Workflow)
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: 7.43.0.Final
    • Fix Version/s: 7.44.0.Final
    • Component/s: KieServer
    • Labels:
      None
    • Docs QE Status:
      NEW
    • QE Status:
      NEW
    • [QE] How to address?:
      ---
    • [QE] Why QE missed?:
      ---

      Description

      After installing manually Kafka WIH defining StringSerializer as class name for key/value serializer, when deploying that unit, the following exception is raised:

      Caused by: org.apache.kafka.common.config.ConfigException: Invalid value org.apache.kafka.common.serialization.StringSerializer for configuration key.serializer: Class org.apache.kafka.common.serialization.StringSerializer could not be found.
      	at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:724)
      	at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:469)
      	at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:462)
      	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:62)
      	at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:75)
      	at org.apache.kafka.clients.producer.ProducerConfig.<init>(ProducerConfig.java:365)
      	at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:303)
      	at org.jbpm.process.workitem.kafka.KafkaWorkItemHandler.<init>(KafkaWorkItemHandler.java:90)
      	... 94 more
      

       exception_kafka_deploy.txt

      Though that dependency is part of the WIH:

      Finally, I could make it work by adding to kie-server.war/WEB-INF/jboss-deployment-structure.xml as dependencies:

      <module name="org.apache.kafka.clients">
      

      where that module has been added to the modules/system/layers/base/org/apache/kafka/clients/main:

      <?xml version="1.0" encoding="UTF-8"?>
      <module name="org.apache.kafka.clients" xmlns="urn:jboss:module:1.8">
          <resources>
              <resource-root path="kafka-clients-2.2.1.jar"/>
      	<resource-root path="lz4-java-1.5.0.jar"/>
          </resources>
          <dependencies>
      	<module name="javax.api"/>
              <module name="org.slf4j"/>
      	<module name="sun.jdk"/>
          </dependencies>
      </module>
      

      with following jars in that module:

      • kafka-clients-2.2.1.jar
      • lz4-java-1.5.0.jar

       

        Attachments

          Activity

            People

            Assignee:
            gonzalomf Gonzalo Muñoz Fernández
            Reporter:
            gonzalomf Gonzalo Muñoz Fernández
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved: