Commit 0e43bdb 1 parent e7d8e76 commit 0e43bdb Copy full SHA for 0e43bdb
File tree 3 files changed +5
-3
lines changed
floodplain-test/src/main/kotlin/io/floodplain/test
3 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -14,8 +14,8 @@ fun isReleaseVersion(): Boolean {
14
14
15
15
object FloodplainDeps {
16
16
const val kotlin = FloodplainPlugins .kotlin
17
- const val floodplain_version = " 1.8.3 -SNAPSHOT"
18
- const val jackson_version = " 2.13.1 "
17
+ const val floodplain_version = " 1.9.1 -SNAPSHOT"
18
+ const val jackson_version = " 2.13.2 "
19
19
const val kafka_version = " 3.0.0"
20
20
const val slf4j_version = " 1.7.36"
21
21
const val mysql_version = " 8.0.23"
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ import io.floodplain.build.FloodplainDeps
3
3
dependencies {
4
4
implementation(FloodplainDeps .kotlinLogging)
5
5
implementation(project(" :floodplain-stream-topology" ))
6
- implementation(" org.mongodb.kafka:mongo-kafka-connect:1.6.1 " )
6
+ implementation(" org.mongodb.kafka:mongo-kafka-connect:1.7.0 " )
7
7
implementation(FloodplainDeps .kafkaConnectRuntime)
8
8
implementation(project(" :streams-api" ))
9
9
implementation(project(" :streams" ))
Original file line number Diff line number Diff line change @@ -113,6 +113,8 @@ class RedpandaContainer(val image: String) : GenericContainer<RedpandaContainer?
113
113
var command = " #!/bin/bash\n "
114
114
command + = " /usr/bin/rpk redpanda start --check=false --node-id 0 "
115
115
command + = " --kafka-addr PLAINTEXT://0.0.0.0:29092,OUTSIDE://0.0.0.0:9092 "
116
+ command + = " --set redpanda.enable_idempotence=true "
117
+ command + = " --set redpanda.enable_transactions=true "
116
118
command + = " --advertise-kafka-addr PLAINTEXT://broker:29092,OUTSIDE://$host :${getMappedPort(9092 )} \n "
117
119
logger.info(" command: $command " )
118
120
logger.info(" mapped port: $host :${getMappedPort(9092 )} " )
You can’t perform that action at this time.
0 commit comments