Commit cd9121dc authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade id único de stream para cada instancia

parent 5e942892

vessels-commands/src/main/resources/application-dev.properties

+1 −1
Original line number Diff line number Diff line
@@ -2,7 +2,7 @@ spring.kafka.bootstrap-servers=localhost:19092 


spring.kafka.properties.schema.registry.url=http://localhost:18081



stream.application.id=${info.microservice.name}

stream.application.id=${spring.kafka.client-id}



broker.state.store.config.dir=/home/REDMIC/kafka

vessels-commands/src/main/resources/application-pre.properties

+1 −1
Original line number Diff line number Diff line
@@ -2,7 +2,7 @@ spring.kafka.bootstrap-servers=kf-1:9092,kf-2:9092,kf-3:9092 


spring.kafka.properties.schema.registry.url=http://schema-registry:8081



stream.application.id=${info.microservice.name}

stream.application.id=${spring.kafka.client-id}



broker.state.store.config.dir=/tmp/kafka

vessels-commands/src/main/resources/application-prod.properties

+1 −1
Original line number Diff line number Diff line
@@ -2,7 +2,7 @@ spring.kafka.bootstrap-servers=kf-1:9092,kf-2:9092,kf-3:9092 


spring.kafka.properties.schema.registry.url=http://schema-registry:8081



stream.application.id=${info.microservice.name}

stream.application.id=${spring.kafka.client-id}



broker.state.store.config.dir=/tmp/kafka

vessels-commands/src/main/resources/application.properties

+5 −3
Original line number Diff line number Diff line
@@ -4,8 +4,6 @@ server.servlet.path=/vessels/commands 


vesseltracking-activity-id=999



stream.application.id=${stream.application.id}



info.microservice.name=@project.name@

info.microservice.description=@project.description@

info.microservice.version=@project.version@
@@ -29,7 +27,10 @@ logging.level.es.redmic=info 
spring.kafka.bootstrap-servers=${spring.kafka.bootstrap-servers}

spring.kafka.consumer.auto-offset-reset=earliest

spring.kafka.listener.ack-mode=record

spring.kafka.consumer.enable-auto-commit=true

spring.kafka.listener.log-container-config=true

spring.kafka.listener.client-id=${spring.kafka.client-id}

spring.kafka.consumer.enable-auto-commit=false



spring.kafka.client-id=@project.name@

spring.kafka.consumer.group-id=@project.name@

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
@@ -98,6 +99,7 @@ broker.topic.vessels.agg.by.vesseltype=vessels-agg-by-vessel-type 
broker.topic.vessel.type.updated=vessel-type-updated



broker.state.store.config.dir=${broker.state.store.config.dir}

stream.application.id=${stream.application.id}



#When an application is updated, the application.id should be changed unless you want to reuse the existing data in internal topics and state stores

broker.state.store.vesseltracking.id=vesselTrackingStore.${stream.application.id}