Skip to content

Commit a7d4ca4

Browse files
Add support for Confluent Kafka 8 (#1053)
1 parent b146b68 commit a7d4ca4

File tree

9 files changed

+300
-130
lines changed

9 files changed

+300
-130
lines changed

docs/modules/kafka.md

Lines changed: 19 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,20 +8,34 @@
88
npm install @testcontainers/kafka --save-dev
99
```
1010

11-
## Examples
11+
## Kafka 8.x
12+
13+
### Examples
14+
15+
<!--codeinclude-->
16+
[Connect to Kafka:](../../packages/modules/kafka/src/kafka-container-latest.test.ts) inside_block:connectKafkaLatest
17+
<!--/codeinclude-->
18+
19+
<!--codeinclude-->
20+
[Connect to Kafka using SSL:](../../packages/modules/kafka/src/kafka-container-latest.test.ts) inside_block:ssl
21+
<!--/codeinclude-->
22+
23+
## Kafka 7.x
24+
25+
### Examples
1226

1327
<!--codeinclude-->
14-
[Connect to Kafka using in-built ZooKeeper:](../../packages/modules/kafka/src/kafka-container.test.ts) inside_block:connectBuiltInZK
28+
[Connect to Kafka using in-built ZooKeeper:](../../packages/modules/kafka/src/kafka-container-7.test.ts) inside_block:connectBuiltInZK
1529
<!--/codeinclude-->
1630

1731
<!--codeinclude-->
18-
[Connect to Kafka using your own ZooKeeper:](../../packages/modules/kafka/src/kafka-container.test.ts) inside_block:connectProvidedZK
32+
[Connect to Kafka using your own ZooKeeper:](../../packages/modules/kafka/src/kafka-container-7.test.ts) inside_block:connectProvidedZK
1933
<!--/codeinclude-->
2034

2135
<!--codeinclude-->
22-
[Connect to Kafka using SSL:](../../packages/modules/kafka/src/kafka-container.test.ts) inside_block:ssl
36+
[Connect to Kafka using SSL:](../../packages/modules/kafka/src/kafka-container-7.test.ts) inside_block:ssl
2337
<!--/codeinclude-->
2438

2539
<!--codeinclude-->
26-
[Connect to Kafka using Kraft:](../../packages/modules/kafka/src/kafka-container.test.ts) inside_block:connectKraft
40+
[Connect to Kafka using Kraft:](../../packages/modules/kafka/src/kafka-container-7.test.ts) inside_block:connectKraft
2741
<!--/codeinclude-->

package-lock.json

Lines changed: 55 additions & 39 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

packages/modules/kafka/Dockerfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
FROM confluentinc/cp-kafka:7.9.1
1+
FROM confluentinc/cp-kafka:8.0.0

packages/modules/kafka/package.json

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
"kafkajs": "^2.2.4"
3333
},
3434
"dependencies": {
35+
"compare-versions": "^6.1.1",
3536
"testcontainers": "^11.1.0"
3637
}
3738
}

0 commit comments

Comments
 (0)