Skip to content

Instantly share code, notes, and snippets.

@feng-tao feng-tao/config1.txt Secret
Last active Aug 29, 2015

Embed
What would you like to do?
Samza config for message passing job
job.factory.class=org.apache.samza.job.local.ProcessJobFactory
task.opts=-Xmx2g -Xloggc:logs/gc.log
metrics.reporter.jmx.class=org.apache.samza.metrics.reporter.JmxReporterFactory
systems.kafka.producer.bootstrap.servers=$LinedIn_bootstrap_server
task.inputs=$input_topic_name
task.class=com.linkedin.samza.example.SimpleTask
systems.kafka.consumer.zookeeper.connect=$LinedIn_zookeeper
systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
task.checkpoint.factory=org.apache.samza.checkpoint.kafka.KafkaCheckpointManagerFactory
systems.kafka.samza.msg.serde=string
systems.kafka.producer.metadata.broker.list=$Linkedin_broker
serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
task.checkpoint.replication.factor=3
task.checkpoint.system=kafka
systems.kafka.samza.key.serde=string
task.command.class=org.apache.samza.job.ShellCommandBuilder
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.