From 95b24da222b3e529cc317429b316578f750f57d8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sindre=20R=C3=B8dseth=20Hansen?= Date: Mon, 25 Nov 2024 12:40:09 +0100 Subject: [PATCH] feat: add kafka transaction topic Co-authored-by: ybelmekk Co-authored-by: Carl Hedgren --- canary-deployer/canary.yaml | 4 ++++ cmd/canary/main.go | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/canary-deployer/canary.yaml b/canary-deployer/canary.yaml index 3db15a4..d3380ae 100644 --- a/canary-deployer/canary.yaml +++ b/canary-deployer/canary.yaml @@ -27,6 +27,10 @@ spec: value: 1s - name: CANARY_KAFKA_TOPIC value: "{{ canary_kafka_topic }}" + - name: CANARY_KAFKA_TRANSACTION_TOPIC + value: "{{ canary_kafka_transaction_topic }}" + - name: CANARY_ENABLE_TRANSACTION + value: "{{ canary_enable_transaction }}" - name: CANARY_KAFKA_GROUP_ID value: "{{ groupid }}" - name: CANARY_LOG_FORMAT diff --git a/cmd/canary/main.go b/cmd/canary/main.go index 066a760..b973c50 100644 --- a/cmd/canary/main.go +++ b/cmd/canary/main.go @@ -44,7 +44,7 @@ const ( MetricsAddress = "metrics-address" SlowConsumer = "slow-consumer" KafkaTransactionTopic = "kafka-transaction-topic" - KafkaTransactionEnable = "enable-transaction-canary" + KafkaTransactionEnable = "enable-transaction" // TODO: kafta-transaction-canary bits // topic + enable,