KafkaPublisher, MqttPublisher
void
asyncPublish(String topic, String payload, Map<String,Object> properties)
publish(String topic, String payload, Map<String,Object> properties)
publishToOperation(String service, String operationName, String payload, Map<String,Object> properties)