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

Exception when deploying WIH Kafka in wildfly/EAP

    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

      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

       

        Gliffy Diagrams

          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: