From f953edc11d993abd6408daf65b86ab28f6fea375 Mon Sep 17 00:00:00 2001 From: etreschenkov Date: Tue, 4 Oct 2022 12:42:47 +0300 Subject: [PATCH] add kafka consumer --- .../src/main/resources/application.properties | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/clearing-parent/dbf-exporter/src/main/resources/application.properties b/clearing-parent/dbf-exporter/src/main/resources/application.properties index deda8d69c..44e7a9fa7 100644 --- a/clearing-parent/dbf-exporter/src/main/resources/application.properties +++ b/clearing-parent/dbf-exporter/src/main/resources/application.properties @@ -11,9 +11,10 @@ export-dbf-service.common.threads-count=10 export-dbf-service.store.out-dir=/opt/clearing/file/exporter/ -import-dbf-service.kafka-consumer.bootstrap-servers=localhost:9092 -import-dbf-service.kafka-consumer.acks=all -import-dbf-service.kafka-consumer.retries=0 -import-dbf-service.kafka-consumer.batch-size=16384 -import-dbf-service.kafka-consumer.linger-ms=1 -import-dbf-service.kafka-consumer.buffer-memory=33554432 \ No newline at end of file +export-dbf-service.kafka-consumer.bootstrap-servers=localhost:9092 +export-dbf-service.kafka-consumer.group-id=dev-group-balance-service +export-dbf-service.kafka-consumer.enable-auto-commit=false +export-dbf-service.kafka-consumer.session-timeout-ms=30000 +export-dbf-service.kafka-consumer.auto-offset-reset=latest +export-dbf-service.kafka-consumer.linger-ms=1 +export-dbf-service.kafka-consumer.buffer-memory=33554432