Class KafkaWorkItemHandler

  • All Implemented Interfaces:
    org.kie.api.runtime.process.WorkItemHandler, org.kie.internal.runtime.Cacheable

    @Wid(widfile="KafkaWorkItem.wid",name="KafkaPublishMessages",displayName="KafkaPublishMessages",defaultHandler="mvel: new org.jbpm.process.workitem.kafka.KafkaWorkItemHandler(\"bootstrapServers\", \"clientId\", \"keySerializerClass\", \"valueSerializerClass\")",documentation="kafka-workitem/index.html",category="kafka-workitem",icon="KafkaPublishMessages.png",parameters={@WidParameter(name="Topic",required=true),@WidParameter(name="Key",required=true),@WidParameter(name="Value",required=true)},results=@WidResult(name="Result"),mavenDepends=@WidMavenDepends(group="org.jbpm.contrib",artifact="kafka-workitem",version="7.71.0-SNAPSHOT"),serviceInfo=@WidService(category="Kafka",description="publish kafka messages from a process",keywords="kafka,publish,message,topic",action=@WidAction(title="Publish message to a kafka topic"),authinfo=@WidAuth(required=true,params={"bootstrapServers","clientId","keySerializerClass","valueSerializerClass"},paramsdescription={"Bootstrap Servers","Client ID","Key Serializer class","Value Serializer class"},referencesite="https://red.ht/kafka-wih-params")))
    public class KafkaWorkItemHandler
    extends org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler
    implements org.kie.internal.runtime.Cacheable
    • Constructor Detail

      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(Properties properties,
                                    org.apache.kafka.clients.producer.Producer producer)
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler()
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(ClassLoader classLoader)
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(ClassLoader classLoader,
                                    org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(String bootstrapServers,
                                    String clientId,
                                    String keySerializerClass,
                                    String valueSerializerClass)
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(String bootstrapServers,
                                    String clientId,
                                    String keySerializerClass,
                                    String valueSerializerClass,
                                    ClassLoader classLoader)
      • KafkaWorkItemHandler

        public KafkaWorkItemHandler​(String bootstrapServers,
                                    String clientId,
                                    String keySerializerClass,
                                    String valueSerializerClass,
                                    ClassLoader classLoader,
                                    org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
    • Method Detail

      • isEmpty

        public boolean isEmpty​(String val)
      • executeWorkItem

        public void executeWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                    org.kie.api.runtime.process.WorkItemManager manager)
        Specified by:
        executeWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • abortWorkItem

        public void abortWorkItem​(org.kie.api.runtime.process.WorkItem workItem,
                                  org.kie.api.runtime.process.WorkItemManager manager)
        Specified by:
        abortWorkItem in interface org.kie.api.runtime.process.WorkItemHandler
      • close

        public void close()
        Specified by:
        close in interface org.kie.internal.runtime.Cacheable
      • getProcessInstanceId

        protected long getProcessInstanceId​(org.kie.api.runtime.process.WorkItem workItem)