Skip to content
Snippets Groups Projects
Commit 61d32276 authored by Sören Henning's avatar Sören Henning
Browse files

Remove unused setting from Beam

parent 52637e5a
Branches
Tags
1 merge request!305Set Kafka Streams commit interval to 5000ms
Pipeline #10161 passed
...@@ -10,11 +10,9 @@ kafka.output.topic=output ...@@ -10,11 +10,9 @@ kafka.output.topic=output
schema.registry.url=http://localhost:8081 schema.registry.url=http://localhost:8081
num.threads=1
commit.interval.ms=1000
cache.max.bytes.buffering=-1
specific.avro.reader=true specific.avro.reader=true
# Kafka Settings
enable.auto.commit=true enable.auto.commit=true
max.poll.records=500 max.poll.records=500
auto.offset.reset=earliest auto.offset.reset=earliest
...@@ -8,11 +8,9 @@ kafka.window.duration.minutes=1 ...@@ -8,11 +8,9 @@ kafka.window.duration.minutes=1
schema.registry.url=http://localhost:8081 schema.registry.url=http://localhost:8081
num.threads=1
commit.interval.ms=1000
cache.max.bytes.buffering=-1
specific.avro.reader=true specific.avro.reader=true
# Kafka Settings
enable.auto.commit=true enable.auto.commit=true
max.poll.records=500 max.poll.records=500
auto.offset.reset=earliest auto.offset.reset=earliest
...@@ -14,11 +14,9 @@ aggregation.advance.days=1 ...@@ -14,11 +14,9 @@ aggregation.advance.days=1
# in seconds # in seconds
trigger.interval=15 trigger.interval=15
num.threads=1
commit.interval.ms=1000
cache.max.bytes.buffering=-1
specific.avro.reader=true specific.avro.reader=true
# Kafka Settings
enable.auto.commit=true enable.auto.commit=true
max.poll.records=500 max.poll.records=500
auto.offset.reset=earliest auto.offset.reset=earliest
...@@ -16,11 +16,9 @@ aggregation.advance.days=1 ...@@ -16,11 +16,9 @@ aggregation.advance.days=1
trigger.interval=15 trigger.interval=15
grace.period.ms=270 grace.period.ms=270
num.threads=1
commit.interval.ms=1000
cache.max.bytes.buffering=-1
specific.avro.reader=true specific.avro.reader=true
# Kafka Settings
enable.auto.commit=true enable.auto.commit=true
max.poll.records=500 max.poll.records=500
auto.offset.reset=earliest auto.offset.reset=earliest
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment