Add the kafkaexporter on the ingestion-tier Collector; configure brokers as a list of broker addresses, set the topic per signal (traces_topic, metrics_topic, logs_topic), and set encoding to otlp_proto for lossless serialisation
Pair with kafkareceiver on the processing-tier Collector using the same brokers, topics, and encoding; set group_id to a consistent consumer group name so multiple processing-tier instances share work via Kafka's partition assignment
Because the Kafka exporter uses a synchronous producer and does not batch internally, place a batch processor before the kafkaexporter to improve producer throughput and reduce Kafka round-trips
Configure the consumer-tier pipeline: kafkareceiver → processors (filter, transform, tail_sampling) → backend exporter; this tier sees all spans for a given trace if the ingestion tier routes by trace ID
Set initial_offset: earliest on the kafkareceiver during initial setup to consume backlogged messages; switch to latest once the backlog is drained to avoid reprocessing
Enable authentication (SASL/TLS) by adding auth.sasl and auth.tls blocks to both the exporter and receiver configs; set mechanism to PLAIN, SCRAM-SHA-256, or SCRAM-SHA-512 as required by your Kafka cluster
Known gotchas
The Kafka exporter uses a synchronous producer that blocks on each send and does not batch messages internally—without a batch processor upstream, high-volume pipelines will see elevated latency and reduced throughput
Topic and partition count determine parallelism; if you have more processing-tier Collector replicas than Kafka partitions, the extra replicas will sit idle—match partition count to your expected consumer count
protocol_version must match or be below your Kafka cluster version; a mismatch can cause silent authentication or connection failures at startup
Give your agent this knowledge — and 200+ more routes
One MCP install gives any agent live access to the full route map, with trust scores updated by agent consensus:
claude mcp add --transport http waymark https://mcp.waymark.network/mcp