Kafka integrations across CDPs

Streams Kafka event data into Bloomreach through elastic.io middleware that reshapes it into Bloomreach's event model, set up with Bloomreach Client Services for recurring syncs.

Listens to Apache Kafka topics and imports their messages into BlueConic profiles, groups and timeline events, running every minute until all messages are ingested.

Publishes messages to a Kafka topic from Fivetran Activations as flat JSON or a mustache template, connecting through bootstrap servers with a username and password.

Apache Kafka. Publishes to Apache Kafka topics each time a row in your warehouse models is inserted, updated or deleted.

Apache Kafka (event source). Consumes JSON messages from an Apache Kafka topic into Hightouch Events as track events, which can then be stored in the warehouse or streamed to destinations.

Publishes mParticle events to Kafka topics on your own bootstrap servers, for real-time pipelines and streaming apps.

Publishes NICE CXone IVR log events to an external Kafka stream that you subscribe to with NICE-issued credentials from allowlisted IP ranges, in a schema format you pick.

Data Management. Streams records between Kafka topics and Redpoint Data Management in both directions with its Kafka Input and Output tools, which use auto-commit only.

Queue provider. Points Redpoint Interaction at a Kafka cluster's bootstrap servers as a queue provider, with settings for acknowledgments, compression, retries, batch size and linger time.

Publishes RudderStack events to Apache Kafka topics for real-time pipelines and streaming applications.

Sends Segment data to Kafka through Actions such as Send (beta).

Replicates Snowplow event streams to Kafka topics through Snowbridge's Kafka target, which supports SASL authentication, TLS and gzip, snappy, lz4 or zstd compression.

Publishes full or custom event, visitor and log data to Apache Kafka topics from AudienceStream or EventStream.

Fluentd consumer. Sends JSON messages from Kafka topics into Treasure Data through the Fluentd consumer for Kafka and a write-only API key, a setup the page describes as beta.

HTTP Sink Connector. Pushes records from Kafka topics on Confluent Cloud, Confluent Platform or Apache Kafka into Treasure Data in near real time through an HTTP Sink Connector calling the Ingestion API.

Destination. Streams event data from Zeotap Journeys into a topic in your Apache Kafka cluster in real time, authenticating to the broker with an API key and secret.

Source. Consumes messages from an Apache Kafka topic into Zeotap through a consumer group, in AVRO or JSON format, so real-time customer behavior can drive journeys.