- 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.17.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://kafka.apache.org/10/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html")))
public class KafkaWorkItemHandler
extends org.jbpm.process.workitem.core.AbstractLogOrThrowWorkItemHandler
implements org.kie.internal.runtime.Cacheable