feat: add kafka transaction topic

Co-authored-by: ybelmekk <[email protected]> Co-authored-by: Carl Hedgren<[email protected]>
nais · Nov 25, 2024 · 95b24da · 95b24da
1 parent b648243
commit 95b24da
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git 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
@@ -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,