Configuration

All Samza jobs have a configuration file that defines the job. A very basic configuration file looks like this:

# Job
job.factory.class=org.apache.samza.job.local.ThreadJobFactory
job.name=hello-world

# Task
task.class=samza.task.example.MyJavaStreamerTask
task.inputs=example-system.example-stream

# Serializers
serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory
serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory

# Systems
systems.example-system.samza.factory=samza.stream.example.ExampleConsumerFactory
systems.example-system.samza.key.serde=string
systems.example-system.samza.msg.serde=json

There are four major sections to a configuration file:

1. The job section defines things like the name of the job, and whether to use the YarnJobFactory or ProcessJobFactory/ThreadJobFactory (See the job.factory.class property in Configuration Table).
2. The task section is where you specify the class name for your StreamTask. It’s also where you define what the input streams are for your task.
3. The serializers section defines the classes of the serdes used for serialization and deserialization of specific objects that are received and sent along different streams.
4. The system section defines systems that your StreamTask can read from along with the types of serdes used for sending keys and messages from that system. Usually, you’ll define a Kafka system, if you’re reading from Kafka, although you can also specify your own self-implemented Samza-compatible systems. See the hello-samza example project’s Wikipedia system for a good example of a self-implemented system.

Required Configuration

Configuration keys that absolutely must be defined for a Samza job are:

• job.factory.class
• job.name
• task.class
• task.inputs

Configuration Keys

A complete list of configuration keys can be found on the Configuration Table page.

Packaging »