From ff1ac1da4fd3771c34637ab1f88b068f3f89f3d7 Mon Sep 17 00:00:00 2001 From: Felix Kunde Date: Tue, 14 Dec 2021 18:48:32 +0100 Subject: [PATCH] replace dash with underscroe for slot name --- pkg/cluster/streams.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/cluster/streams.go b/pkg/cluster/streams.go index 86e3687db..101d350db 100644 --- a/pkg/cluster/streams.go +++ b/pkg/cluster/streams.go @@ -217,7 +217,7 @@ func getOutboxTable(tableName, idColumn string) zalandov1alpha1.EventStreamTable func (c *Cluster) getStreamConnection(database, user, appId string) zalandov1alpha1.Connection { return zalandov1alpha1.Connection{ Url: fmt.Sprintf("jdbc:postgresql://%s.%s/%s?user=%s&ssl=true&sslmode=require", c.Name, c.Namespace, database, user), - SlotName: constants.EventStreamSourceSlotPrefix + "_" + database + "_" + appId, + SlotName: constants.EventStreamSourceSlotPrefix + "_" + database + "_" + strings.Replace(appId, "-", "_", -1), DBAuth: zalandov1alpha1.DBAuth{ Type: constants.EventStreamSourceAuthType, Name: c.credentialSecretNameForCluster(user, c.Name),