@@ -13,7 +13,7 @@ internal object Configuration {
13
13
Profile .PROD .pair(),
14
14
15
15
" HTTP_PORT" to " 8080" ,
16
-
16
+ " kafka.aiven.consumer " to " hm-oebs-listener-v1 " ,
17
17
" kafka.aiven.topic" to " teamdigihot.hm-soknadsbehandling-v1" ,
18
18
" kafka.reset.policy" to " latest" ,
19
19
@@ -22,12 +22,10 @@ internal object Configuration {
22
22
23
23
private val devProperties = ConfigurationMap (
24
24
Profile .DEV .pair(),
25
-
26
25
" HTTP_PORT" to " 8080" ,
27
-
26
+ " kafka.aiven.consumer " to " hm-oebs-listener-v2 " ,
28
27
" kafka.aiven.topic" to " teamdigihot.hm-soknadsbehandling-v1" ,
29
28
" kafka.reset.policy" to " latest" ,
30
-
31
29
" SENSU_URL" to " https://digihot-proxy.dev-fss-pub.nais.io/sensu" ,
32
30
)
33
31
@@ -37,6 +35,7 @@ internal object Configuration {
37
35
" HTTP_PORT" to " 8085" ,
38
36
" OEBSTOKEN" to " abc" ,
39
37
38
+ " kafka.aiven.consumer" to " hm-oebs-listener-v1" ,
40
39
" kafka.aiven.topic" to " teamdigihot.hm-soknadsbehandling-v1" ,
41
40
" kafka.reset.policy" to " earliest" ,
42
41
" kafka.brokers" to " host.docker.internal:9092" ,
@@ -61,7 +60,7 @@ internal object Configuration {
61
60
" RAPID_KAFKA_CLUSTER" to " gcp" ,
62
61
" RAPID_APP_NAME" to " hm-oebs-listener" ,
63
62
" KAFKA_BROKERS" to get(" kafka.brokers" ),
64
- " KAFKA_CONSUMER_GROUP_ID" to " hm-oebs-listener-v1 " ,
63
+ " KAFKA_CONSUMER_GROUP_ID" to get( " kafka.aiven.consumer " ) ,
65
64
" KAFKA_RAPID_TOPIC" to get(" kafka.aiven.topic" ),
66
65
" KAFKA_RESET_POLICY" to get(" kafka.reset.policy" ),
67
66
" KAFKA_KEYSTORE_PATH" to get(" KAFKA_KEYSTORE_PATH" ),
0 commit comments