change Kafka admin id warehouse->kafkatorio

2022-04-20 23:17:50 +02:00 · 2022-04-20 23:17:50 +02:00 · f339333f76
commit f339333f76
parent bb54f6666b
1 changed files with 1 additions and 1 deletions
--- 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",
      )
    )