Skip to content

Client Data Flow Sequence Diagrams

This content is for the 3.3.6 version. Switch to the latest version for up-to-date documentation.

JMS Producer to Kafka Consumer Flow

Kafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerKafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerConfluent PlatformAll JMS properties are converted to Kafka headers with a prefix of ‘jms’. Origin header is also addedExclusive divert using a selector prevents JMS queues from getting dupes and data cycles.Publishes data to topic

JMS Producer to Kafka Consumer Flow - Error Flow

Kafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerKafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerErrors between these points will go back to the publisherErrors between these points will go back to the publisherTypical InteractionBoom

Kafka Producer to JMS Consumer Flow

Kafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerKafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerMessage is tagged with an origin header to prevent data cycles.If no consumer queue is bound to the topic, then the message is unrouted and not persisted.

Kafka Producer to JMS Consumer - Error Flow

Kafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerKafka ProducerKafka ConsumerOrdersKafka Egress ProcessKafka Ingress ProcessKafka Exchange QueueDivertJMS Topic 'orders'JMS PublisherJMS QueueJMS ConsumerErrors between these points will go back to Kafka