From fa9c67b97c26571d29bdd74d5b9e2b422ccc42f8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sercan=20=C3=87elenk?= Date: Tue, 12 Mar 2024 12:38:27 +0300 Subject: [PATCH] Updated readme --- README.md | 26 +++++++++++++++++--------- pom.xml | 1 - 2 files changed, 17 insertions(+), 10 deletions(-) diff --git a/README.md b/README.md index 4b3387d..f1f0f9a 100644 --- a/README.md +++ b/README.md @@ -93,17 +93,25 @@ This is an example of how to list things you need to use the software and how to ``` kafkathena: shared-factory-props: - autoStartup: true - missingTopicAlertEnable: false - concurrency: 1 - syncCommitTimeoutSecond: 5 - syncCommit: true - ackMode: RECORD - interceptorClassPath: com.trendyol.kafkathena.demo.interceptor.KafkaConsumerInterceptor + producer: + interceptor: "com.trendyol.mpc.kafkathena.commons.interceptor.KSProducerInterceptor" + consumer: + interceptor: "com.trendyol.mpc.kafkathena.commons.interceptor.KSConsumerInterceptor" + autoStartup: true + missingTopicAlertEnable: false + concurrency: 1 + syncCommitTimeoutSecond: 5 + syncCommit: true + batch: false + ackMode: RECORD + clusters: + "[confluent]": + servers: localhost:9092 + producers: default: + cluster: confluent props: - "[bootstrap.servers]": ${KAFKA_BOOTSTRAP_SERVERS:localhost:29092} "[batch.size]": 16384 "[linger.ms]": 0 "[buffer.memory]": 33554432 @@ -118,6 +126,7 @@ kafkathena: factory-bean-name: consumerOneKafkaListenerContainerFactory data-class: com.trendyol.kafkathena.demo.model.ConsumerOneMessage error-producer-name: default + cluster: confluent filter-header: error-producer-filter-key: one-filter consumer-filter-key: one-filter @@ -141,7 +150,6 @@ kafkathena: ack-mode: : RECORD interceptor-class-path: : com.trendyol.kafkathena.demo.interceptor.KafkaConsumerInterceptor props: - "[bootstrap.servers]": ${KAFKA_BOOTSTRAP_SERVERS:localhost:29092} "[group.id]": kafkathena.topicOneGroup "[value.deserializer]": org.springframework.kafka.support.serializer.ErrorHandlingDeserializer "[spring.deserializer.value.delegate.class]": org.springframework.kafka.support.serializer.JsonDeserializer diff --git a/pom.xml b/pom.xml index a0c4987..955b235 100644 --- a/pom.xml +++ b/pom.xml @@ -54,7 +54,6 @@ 17 17 - 4093 1.0.0