File tree Expand file tree Collapse file tree 1 file changed +8
-5
lines changed
src/main/kotlin/infrastructure/kafka Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -22,10 +22,13 @@ class KafkaPublisher : EventPublisher<Event<Any>> {
22
22
init {
23
23
listOf (System .getenv(" BOOTSTRAP_SERVER_URL" ), System .getenv(" SCHEMA_REGISTRY_URL" )).forEach {
24
24
requireNotNull(it) {
25
- println ("""
26
- Invalid environment variable!
27
- Check the documentation here: https://github.com/SmartOperatingBlock/bootstrap")
28
- """ .trimIndent())
25
+ println (
26
+ """
27
+ Invalid environment variable!
28
+ Check the documentation here:
29
+ https://github.com/SmartOperatingBlock/bootstrap")"""
30
+ .trimIndent()
31
+ )
29
32
}
30
33
}
31
34
}
@@ -35,7 +38,7 @@ class KafkaPublisher : EventPublisher<Event<Any>> {
35
38
" schema.registry.url" to System .getenv(" SCHEMA_REGISTRY_URL" ),
36
39
" key.serializer" to " org.apache.kafka.common.serialization.StringSerializer" ,
37
40
" value.serializer" to KafkaJsonSerializer ::class .java
38
- )
41
+ )
39
42
40
43
private val eventToTopic: Map <String , String > = mapOf (
41
44
" ROOM_EVENT" to " room-events" ,
You can’t perform that action at this time.
0 commit comments