Skip to content

Commit

Permalink
update confluent code sample for 0.11
Browse files Browse the repository at this point in the history
  • Loading branch information
jerrinot committed Apr 9, 2024
1 parent 7426896 commit 7020ac2
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 7 deletions.
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
FROM confluentinc/cp-kafka-connect-base:7.6.0
RUN confluent-hub install --no-prompt questdb/kafka-questdb-connector:0.8
RUN confluent-hub install --no-prompt questdb/kafka-questdb-connector:0.11
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,7 @@ services:
KAFKA_CLUSTERS_0_KAFKACONNECT_0_NAME: connect
KAFKA_CLUSTERS_0_KAFKACONNECT_0_ADDRESS: http://connect:8083
questdb:
image: questdb/questdb:7.0.1
expose:
- "9009"
image: questdb/questdb:7.4.0
ports:
- "9000:9000"
environment:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,8 @@ It also uses the [Kafka UI](https://github.com/provectus/kafka-ui) project for K
{
"connector.class": "io.questdb.kafka.QuestDBSinkConnector",
"topics": "Orders",
"host": "questdb:9009",
"client.conf.string": "http::addr=questdb:9000;",
"timestamp.kafka.native": true,
"name": "questdb",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"include.key": false,
Expand Down Expand Up @@ -56,8 +57,8 @@ The Docker Compose file starts the following containers:

The Kafka Connect container is built from the [Confluent CP Kafka Connect](https://hub.docker.com/r/confluentinc/cp-kafka-connect-base) by image by using the following Dockerfile:
```dockerfile
FROM confluentinc/cp-kafka-connect-base:7.3.2
RUN confluent-hub install --no-prompt questdb/kafka-questdb-connector:0.6
FROM confluentinc/cp-kafka-connect-base:7.6.0
RUN confluent-hub install --no-prompt questdb/kafka-questdb-connector:0.11
```
The `confluent-hub` command installs the QuestDB Kafka connector from the [Confluent Hub](https://www.confluent.io/hub/questdb/kafka-questdb-connector).

Expand Down

0 comments on commit 7020ac2

Please sign in to comment.