As part of the integration story with AMQ streams one of the capabilities should be to have a kie-server extension that could produce events to a Kafka topic using End or Intermediate Throw Events (Signals/Messages) designed as part of the process.

In order to achieve that this Jira:

• Adds two now events to ProcessEventListener, SignalEvent and MessageEvent, to ProcessEventListener, that are fired when a signal or a message is triggered as consquence of process execution (IntermediateThrowEvent or EndEvent)
• Kafka Extension listen for these event. when received it send a Kafka record to the proper topic. The value of the record is a cloudevent, which data field contains a json representation of the object associated to the signal/message.
• Topic is determined by looking up to a system property org.kie.server.jbpm-kafka.ext.<message/signal name>=<topicName>. If no such property exist, then the name of message/signal is used as topic