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", ) )