Kafka Consumer

ID	product.ingestion.stream_router.kafka_consumer
Description	Subscribes to source topics on the platform bus.
Key	kafka_consumer
Type	component
Status	active
Team	Data Ingestion
Owner	ingestion@dataplatform.example
Tags

Table of contents

Guide

Kafka Consumer

Subscribes to source topics on the platform bus.

Component

Internal module inside Stream Router. See the parent container guide for the end-to-end flow this component participates in.

2 incoming links · 1 workflow · 2 async channels

Source object	Label	Link type	Relation	Raw id	Required	Description
Deduplicator example-data-processing.product.ingestion.stream_router.deduplicator component	—	—	links	product.ingestion.stream_router.kafka_consumer	—	—
Dead Letter Handler example-data-processing.product.ingestion.stream_router.dead_letter_handler component	—	—	links	product.ingestion.stream_router.kafka_consumer	—	—

Channel	Broker	Producer
CDC change events cdc.public · topic	Event Bus external_systems.event_bus	Production Databases
Domain events domain.events · topic	Event Bus external_systems.event_bus	Stream Pipeline

Channel

Broker

Producer

CDC change events

cdc.public · topic

Domain events

domain.events · topic

Workflow	Model	Participant id	Participant label
Real-time event ingestion streaming.realtime-event	example-data-processing	product.ingestion.stream_router.kafka_consumer	Kafka consumer