#  Application
app.runner.class=org.apache.samza.runtime.LocalApplicationRunner

# Job
job.coordinator.factory=org.apache.samza.zk.ZkJobCoordinatorFactory
job.coordinator.zk.connect=localhost:2181
job.coordinator.system=kafka
job.default.system=kafka

# Kafka System
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.consumer.zookeeper.connect=localhost:2181
systems.kafka.producer.bootstrap.servers=localhost:9092
systems.kafka.producer.retries=3
systems.kafka.producer.retry.backoff.ms=200
systems.kafka.default.stream.replication.factor=1

# Task
task.name.grouper.factory=org.apache.samza.container.grouper.task.GroupByContainerIdsFactory
task.shutdown.ms=5000
task.class=org.apache.samza.task.StreamOperatorTask
# checkpoint configuration
task.checkpoint.factory=org.apache.samza.checkpoint.kafka.KafkaCheckpointManagerFactory
task.checkpoint.system=kafka
# By default, a checkpoint is written every 60 seconds. You can change this.
task.commit.ms=2000

