@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.56.0.Final"),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
Modifier and Type | Class and Description |
---|---|
static class |
KafkaWorkItemHandler.KafkaWorkItemHandlerProducerCommand |
Constructor and Description |
---|
KafkaWorkItemHandler() |
KafkaWorkItemHandler(ClassLoader classLoader) |
KafkaWorkItemHandler(ClassLoader classLoader,
org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager) |
KafkaWorkItemHandler(Properties properties,
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) |
KafkaWorkItemHandler(String bootstrapServers,
String clientId,
String keySerializerClass,
String valueSerializerClass,
ClassLoader classLoader,
org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager) |
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) |
protected long |
getProcessInstanceId(org.kie.api.runtime.process.WorkItem workItem) |
boolean |
isEmpty(String val) |
public KafkaWorkItemHandler(Properties properties, org.apache.kafka.clients.producer.Producer producer)
public KafkaWorkItemHandler()
public KafkaWorkItemHandler(ClassLoader classLoader)
public KafkaWorkItemHandler(ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass)
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader)
public KafkaWorkItemHandler(String bootstrapServers, String clientId, String keySerializerClass, String valueSerializerClass, ClassLoader classLoader, org.kie.internal.runtime.manager.InternalRuntimeManager runtimeManager)
public boolean isEmpty(String val)
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
protected long getProcessInstanceId(org.kie.api.runtime.process.WorkItem workItem)
Copyright © 2001–2021 JBoss by Red Hat. All rights reserved.