From f339333f76b1593e961f631d36a92dd8b0a7666b Mon Sep 17 00:00:00 2001 From: Adam <897017+aSemy@users.noreply.github.com> Date: Wed, 20 Apr 2022 23:17:50 +0200 Subject: [PATCH] change Kafka admin id warehouse->kafkatorio --- .../adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt index 27f4a17..b0fbb20 100644 --- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt +++ b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/admin/KafkatorioKafkaAdmin.kt @@ -16,7 +16,7 @@ object KafkatorioKafkaAdmin { Admin.create( mapOf( "bootstrap.servers" to "http://localhost:9092", - "client.id" to "warehouse.setup-admin", + "client.id" to "kafkatorio.setup-admin", ) )