diff --git a/broker/consumer/rubin/ps-connector.properties b/broker/consumer/rubin/ps-connector.properties index 60a5d024..f76775fc 100644 --- a/broker/consumer/rubin/ps-connector.properties +++ b/broker/consumer/rubin/ps-connector.properties @@ -12,7 +12,7 @@ tasks.max=1 # set kafka the topic topics=KAFKA_TOPIC # set the Pub/Sub configs -cps.topic=PUBSUB_TOPIC +cps.topic=PS_TOPIC cps.project=PROJECT_ID # include Kafka topic, partition, offset, timestamp as msg attributes metadata.publish=true