Permalink
Cannot retrieve contributors at this time
Join GitHub today
GitHub is home to over 28 million developers working together to host and review code, manage projects, and build software together.
Sign up
Fetching contributors…
Cannot retrieve contributors at this time
| # Licensed to the Apache Software Foundation (ASF) under one | |
| # or more contributor license agreements. See the NOTICE file | |
| # distributed with this work for additional information | |
| # regarding copyright ownership. The ASF licenses this file | |
| # to you under the Apache License, Version 2.0 (the | |
| # "License"); you may not use this file except in compliance | |
| # with the License. You may obtain a copy of the License at | |
| # | |
| # http://www.apache.org/licenses/LICENSE-2.0 | |
| # | |
| # Unless required by applicable law or agreed to in writing, | |
| # software distributed under the License is distributed on an | |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | |
| # KIND, either express or implied. See the License for the | |
| # specific language governing permissions and limitations | |
| # under the License. | |
| # Job | |
| job.factory.class=org.apache.samza.job.yarn.YarnJobFactory | |
| job.name=kinesis-hello-samza | |
| job.systemstreampartition.grouper.factory=org.apache.samza.container.grouper.stream.AllSspToSingleTaskGrouperFactory | |
| # YARN | |
| yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.tar.gz | |
| yarn.container.count=2 | |
| # Task | |
| task.class=samza.examples.kinesis.KinesisHelloSamza | |
| # Please replace the below input stream with the stream you plan to consume from. | |
| task.inputs=kinesis.kinesis-samza-sample-stream | |
| # Serializers | |
| serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory | |
| # Kinesis System | |
| systems.kinesis.samza.factory=org.apache.samza.system.kinesis.KinesisSystemFactory | |
| # Please replace the below with the region of your Kinesis data stream. | |
| systems.kinesis.streams.kinesis-samza-sample-stream.aws.region=us-west-1 | |
| # Access key below is a dummy key for instructional purposes. Please replace with your own key. | |
| systems.kinesis.streams.kinesis-samza-sample-stream.aws.accessKey=AKIAIHSMRK3Q72O8TEXQ | |
| # Secret key below is a dummy key for instructional purposes. Please replace with your own key. | |
| sensitive.systems.kinesis.streams.kinesis-samza-sample-stream.aws.secretKey=9GuEqdY+gNXXGrOQyev8XKziY+sRB1ht91jloEyP | |
| systems.kinesis.streams.kinesis-samza-sample-stream.aws.kcl.TableName=kinesis-hello-samza | |
| # Kafka System | |
| systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory | |
| systems.kafka.samza.msg.serde=json | |
| systems.kafka.consumer.zookeeper.connect=localhost:2181/ | |
| systems.kafka.producer.bootstrap.servers=localhost:9092 | |
| # Job Coordinator | |
| job.coordinator.system=kafka | |
| job.coordinator.replication.factor=1 |