---

dmitriev-aal@VDI-Dmitriev-A:~/Desktop/rshbintech/it-invest/backoffice/myinvestment/depo-invoice$ kubectl --context devstbl -n isys-myinvestment-dev \
>   logs depo-invoice-7696fbfbfd-8fmq6 -c app | \
>   grep -Ei 'AdminClient|localhost:9092|sinv.depo.invoices.snapshot|peinvest|KafkaTopicProvisioner'
{"timestamp":"2026-08-27 09:16:17.250","message":"AdminClientConfig values: \n\tauto.include.jmx.reporter = true\n\tbootstrap.controllers = []\n\tbootstrap.servers = [adapter-ips-appfarm-kafka.isys-myinvestment-dev-links:9092]\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = depo-invoice-admin-0\n\tconnections.max.idle.ms = 300000\n\tdefault.api.timeout.ms = 60000\n\tenable.metrics.push = true\n\tmetadata.max.age.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 30000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n","logger_name":"org.apache.kafka.clients.admin.AdminClientConfig","thread_name":"main","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.327","message":"Using kafka topic for outbound: sinv.notification-aggregator.depo","logger_name":"org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner","thread_name":"quartzScheduler_Worker-1","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.328","message":"AdminClientConfig values: \n\tauto.include.jmx.reporter = true\n\tbootstrap.controllers = []\n\tbootstrap.servers = [adapter-sinv-int-sinv-int-1.isys-myinvestment-dev-links:9092]\n\tclient.dns.lookup = use_all_dns_ips\n\tclient.id = \n\tconnections.max.idle.ms = 300000\n\tdefault.api.timeout.ms = 60000\n\tenable.metrics.push = true\n\tmetadata.max.age.ms = 300000\n\tmetadata.recovery.strategy = none\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 30000\n\tretries = 2147483647\n\tretry.backoff.max.ms = 1000\n\tretry.backoff.ms = 100\n\tsasl.client.callback.handler.class = null\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.connect.timeout.ms = null\n\tsasl.login.read.timeout.ms = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\n\tsasl.login.retry.backoff.max.ms = 10000\n\tsasl.login.retry.backoff.ms = 100\n\tsasl.mechanism = GSSAPI\n\tsasl.oauthbearer.clock.skew.seconds = 30\n\tsasl.oauthbearer.expected.audience = null\n\tsasl.oauthbearer.expected.issuer = null\n\tsasl.oauthbearer.header.urlencode = false\n\tsasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000\n\tsasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100\n\tsasl.oauthbearer.jwks.endpoint.url = null\n\tsasl.oauthbearer.scope.claim.name = scope\n\tsasl.oauthbearer.sub.claim.name = sub\n\tsasl.oauthbearer.token.endpoint.url = null\n\tsecurity.protocol = PLAINTEXT\n\tsecurity.providers = null\n\tsend.buffer.bytes = 131072\n\tsocket.connection.setup.timeout.max.ms = 30000\n\tsocket.connection.setup.timeout.ms = 10000\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.3]\n\tssl.endpoint.identification.algorithm = https\n\tssl.engine.factory.class = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.certificate.chain = null\n\tssl.keystore.key = null\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLSv1.3\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.certificates = null\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n","logger_name":"org.apache.kafka.clients.admin.AdminClientConfig","thread_name":"quartzScheduler_Worker-1","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.449","message":"App info kafka.admin.client for adminclient-1 unregistered","logger_name":"org.apache.kafka.common.utils.AppInfoParser","thread_name":"kafka-admin-client-thread | adminclient-1","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.463","message":"Metrics scheduler closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"kafka-admin-client-thread | adminclient-1","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.464","message":"Closing reporter org.apache.kafka.common.metrics.JmxReporter","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"kafka-admin-client-thread | adminclient-1","level":"INFO"}
{"timestamp":"2026-08-28 09:00:00.464","message":"Metrics reporters closed","logger_name":"org.apache.kafka.common.metrics.Metrics","thread_name":"kafka-admin-client-thread | adminclient-1","level":"INFO"}
dmitriev-aal@VDI-Dmitriev-A:~/Desktop/rshbintech/it-invest/backoffice/myinvestment/depo-invoice$ git show --stat 05371d24
commit 05371d248be86b7a7b561d05b71fd6425dbead22 (HEAD, origin/master, origin/HEAD, master)
Merge: 7641c8c 57465cb
Author: Артем Капоров (GitLab) <kaporovase@avt.rshb.ru>
Date:   Fri Sep 18 10:11:17 2026 +0300

    Merge branch 'feature/AVT_BOSS-7319' into 'master'
    
    AVT_BOSS-7319 Adding peinvest-kafka cluster and strategyType
    
    See merge request rshbintech/it-invest/backoffice/myinvestment/depo-invoice!74

 deploy/envs/default/values.yaml    | 3 +++
 src/main/resources/application.yml | 7 ++++++-
 2 files changed, 9 insertions(+), 1 deletion(-)
dmitriev-aal@VDI-Dmitriev-A:~/Desktop/rshbintech/it-invest/backoffice/myinvestment/depo-invoice$ git show --first-parent 05371d24 -- \
>   src/main/resources/application.yml \
>   deploy/envs/default/values.yaml
commit 05371d248be86b7a7b561d05b71fd6425dbead22 (HEAD, origin/master, origin/HEAD, master)
Merge: 7641c8c 57465cb
Author: Артем Капоров (GitLab) <kaporovase@avt.rshb.ru>
Date:   Fri Sep 18 10:11:17 2026 +0300

    Merge branch 'feature/AVT_BOSS-7319' into 'master'
    
    AVT_BOSS-7319 Adding peinvest-kafka cluster and strategyType
    
    See merge request rshbintech/it-invest/backoffice/myinvestment/depo-invoice!74

diff --git a/deploy/envs/default/values.yaml b/deploy/envs/default/values.yaml
index 0a4eda5..8ea2045 100644
--- a/deploy/envs/default/values.yaml
+++ b/deploy/envs/default/values.yaml
@@ -14,6 +14,7 @@ resources:
 env:
   APP_PLATFORM_IPS_KAFKA_BOOTSTRAP_SERVERS: "appfarm://kafka-bootstrap:ips/appfarm-kafka"
   APP_PLATFORM_SINV_KAFKA_BOOTSTRAP_SERVERS: "appfarm://kafka-bootstrap:sinv-int/sinv-int-1"
+  APP_PLATFORM_PEINVEST_KAFKA_BOOTSTRAP_SERVERS: "appfarm://kafka-bootstrap:myinvestment/peinvest-appfarm-kafka"
   KAFKA_TOPIC_SINV_SEND_DEPO_INVOICE_INFO: "ips.send-depo-invoice-info"
   PRODUCER_TOPIC_NOTIFICATION_SEND: "sinv.notification-aggregator.depo"
   KAFKA_GROUP_NOTIFICATION_FROM_DIASOFT: "DEPO_INVOICE_GROUP"
@@ -37,6 +38,8 @@ probes:
     successThreshold: 1
     failureThreshold: 5
 
+strategyType: RollingUpdate
+
 links:
   - targetProtocol: "KAFKA"
     targetInformationSystemId: "ips"
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 323a6ca..02fb85e 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -56,7 +56,7 @@ spring:
           group: ${KAFKA_GROUP_NOTIFICATION_FROM_DIASOFT}
 
         snapShot-out-0:
-          binder: sinv-kafka
+          binder: peinvest-kafka
           destination: sinv.depo.invoices.snapshot
           group: ${KAFKA_GROUP_NOTIFICATION_FROM_DIASOFT}
 
@@ -66,6 +66,11 @@ spring:
           environment:
             spring.cloud.stream.kafka.binder:
               brokers: ${APP_PLATFORM_SINV_KAFKA_BOOTSTRAP_SERVERS}
+        peinvest-kafka:
+          type: kafka
+          environment:
+            spring.cloud.stream.kafka.binder:
+              brokers: ${APP_PLATFORM_PEINVEST_KAFKA_BOOTSTRAP_SERVERS}
 
   jpa:
     properties:
dmitriev-aal@VDI-Dmitriev-A:~/Desktop/rshbintech/it-invest/backoffice/myinvestment/depo-invoice$