summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-05-13 18:04:08 +0800
committerdoufenghu <[email protected]>2024-05-13 18:04:08 +0800
commite819d35d0adfb6cc8dae823bf3635e1f93ced81a (patch)
tree0dbea092d7c92bd1ea5d0cdf67d4a5e88a0c1bc1
parentdf696e2f65227b950fcde0a51b7ca0f717b2becd (diff)
更新默认配置kafka consumer/producer参数
-rw-r--r--properties/application.properties18
1 files changed, 9 insertions, 9 deletions
diff --git a/properties/application.properties b/properties/application.properties
index 7fc84d0..10c3aae 100644
--- a/properties/application.properties
+++ b/properties/application.properties
@@ -8,9 +8,9 @@ source.kafka.props.group.id=appapp-protocol-merge-231109-1
source.kafka.props.max.poll.records=1000
-source.kafka.session.timeout.ms=60000
+source.kafka.props.session.timeout.ms=60000
-source.kafka.max.partition.fetch.bytes=31457280
+source.kafka.props.max.partition.fetch.bytes=31457280
source.kafka.props.security.protocol=SASL_PLAINTEXT
@@ -26,19 +26,19 @@ sink.kafka.props.bootstrap.servers=192.168.44.12:9094
sink.kafka.props.linger.ms=1
-sink.kafka.acks=1
+sink.kafka.props.acks=1
-sink.kafka.retries=0
+sink.kafka.props.retries=0
-sink.kafka.request.timeout.ms=30000
+sink.kafka.props.request.timeout.ms=30000
-sink.kafka.batch.size=262144
+sink.kafka.props.batch.size=262144
-sink.kafka.buffer.memory=134217728
+sink.kafka.props.buffer.memory=134217728
-sink.kafka.max.request.size=10485760
+sink.kafka.props.max.request.size=10485760
-sink.kafka.compression.type=snappy
+sink.kafka.props.compression.type=snappy
sink.kafka.props.security.protocol=SASL_PLAINTEXT