diff --git a/backend/provisioner/dev_provisioner.go b/backend/provisioner/dev_provisioner.go index 51fd894d6..ce0da6cba 100644 --- a/backend/provisioner/dev_provisioner.go +++ b/backend/provisioner/dev_provisioner.go @@ -265,11 +265,11 @@ func provisionSubscription() func(ctx context.Context, rc *provisioner.ResourceC } func kafkaTopicID(module, id string) string { - return shortenString(fmt.Sprintf("%s-%s", module, id), pubSubNameLimit) + return shortenString(fmt.Sprintf("%s.%s", module, id), pubSubNameLimit) } func consumerGroupID(module, id string) string { - return shortenString(fmt.Sprintf("%s-%s", module, id), pubSubNameLimit) + return shortenString(fmt.Sprintf("%s.%s", module, id), pubSubNameLimit) } // shortenString truncates the input string to maxLength and appends a hash of the original string for uniqueness