@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.45.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
Constructor and Description |
---|
KafkaWorkItemHandler(org.apache.kafka.clients.producer.Producer producer) |
KafkaWorkItemHandler(String bootstrapServers,
String clientId,
String keySerializerClass,
String valueSerializerClass) |
KafkaWorkItemHandler(String bootstrapServers,
String clientId,
String keySerializerClass,
String valueSerializerClass,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
abortWorkItem(org.kie.api.runtime.process.WorkItem workItem,
org.kie.api.runtime.process.WorkItemManager manager) |
void |
close() |
void |
executeWorkItem(org.kie.api.runtime.process.WorkItem workItem,
org.kie.api.runtime.process.WorkItemManager manager) |
public KafkaWorkItemHandler(org.apache.kafka.clients.producer.Producer producer)
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader)
public void executeWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
executeWorkItem
in interface org.kie.api.runtime.process.WorkItemHandler
public void abortWorkItem(org.kie.api.runtime.process.WorkItem workItem, org.kie.api.runtime.process.WorkItemManager manager)
abortWorkItem
in interface org.kie.api.runtime.process.WorkItemHandler
public void close()
close
in interface org.kie.internal.runtime.Cacheable
Copyright © 2001–2020 pnairatl@gmail.com. All rights reserved.