---
title: "Integrating ClickHouse with Kafka"
description: "Integration with Apache Kafka, the open-source distributed event streaming platform"
category: "DATA_INGESTION"
support: "CORE"
docs: "https://clickhouse.com/docs/integrations/connectors/data-ingestion/kafka"
---

# Kafka

Options for integrating ClickHouse Cloud with Apache Kafka include:
- <a href="https://clickhouse.com/docs/en/integrations/kafka/kafka-connect-intro" target="_blank">Kafka Connect</a> - Kafka Connect is a free, open-source component of Apache Kafka® that works as a centralized data hub for simple data integration between Kafka and other data systems. This is the option we cover here in detail.
- <a href="https://clickhouse.com/docs/en/integrations/kafka/kafka-vector" target="_blank">Vector</a> - Vector is a vendor agnostic data pipeline. With the ability to read from Kafka, and send events to ClickHouse, this represents a robust integration option.

### Confluent Platform
Confluent Platform is a full-scale data streaming platform that enables you to easily access, store, and manage data as continuous, real-time streams.<br />
Confluent solution is provided as On Prem & Cloud Solutions.<br />
ClickHouse Cloud is only supported on the On Prem and is enabled by using the JdbcSinkConnector.

#### How to configure Local Single node installation for Confluent




Install Confluent - we recommend the <a href="https://docs.confluent.io/platform/current/quickstart/ce-docker-quickstart.html" target="_blank">Quick Start for Confluent Platform</a>




Install ClickHouse-JDBC Driver - Download the latest version of ClickHouse-JDBC version into Confluent directory.
```shell
    wget https://repo1.maven.org/maven2/com/clickhouse/clickhouse-jdbc/0.3.2-   patch11/clickhouse-jdbc-0.3.2-patch11.jar
```




Start Confluent instance.




#### Prepare configuration in the UI




Create a database and a table in ClickHouse




Create a Kafka topic that our JdbcSinkConnector can pull messages from. Call it `ClickHouse Cloud`




Create a new JdbcSinkConnector with this configuration and provide endpoint, password and username properties:
```json
{
  "name": "JdbcSinkConnectorConnector_0",
  "config": {
    "name": "JdbcSinkConnectorConnector_0",
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "topics": "test_v1",
    "connection.url": "jdbc:clickhouse://<host>:8443/default?ssl=true",
    "connection.user": "default",
    "connection.password": "<password>",
    "dialect.name": "GenericDatabaseDialect",
    "auto.create": "false"
  }
}
```




Press `Launch` and data will start to flow!