Pass LVK kafka metadata to pubsub attributes (#237)

mwvgroup · Sep 12, 2024 · 70fdddc · 70fdddc
1 parent c0a8e48
commit 70fdddc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/broker/consumer/lvk/ps-connector.properties b/broker/consumer/lvk/ps-connector.properties
@@ -29,4 +29,6 @@ value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
 topics=KAFKA_TOPIC
 # Set the Pub/Sub configs
 cps.project=PROJECT_ID
-cps.topic=PS_TOPIC
+cps.topic=PS_TOPIC
+# include Kafka topic, partition, offset, timestamp as msg attributes
+metadata.publish=true