[ 
https://issues.apache.org/jira/browse/SAMZA-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14632169#comment-14632169
 ] 

Carl Laird commented on SAMZA-737:
----------------------------------

Hi Yi Pan.

Thanks for your reply.

The two properties are in the section headed by the following:
Using Kafka for input streams, output streams and checkpoints
(This section applies if you have set systems.*.samza.factory = 
org.apache.samza.system.kafka.KafkaSystemFactory)

so I assumed the properties just apply to kafka.

I found that neither property works as listed in the documentation, but they do 
work if I change them to stores.store-name.changelog.kafka.replication.factor 
and stores.store-name.changelog.kafka.topic-level-property.

See KafkaConfig.CHANGELOG_STREAM_KAFKA_SETTINGS in 
https://github.com/apache/samza/blob/master/samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala.




> config docs: property names stores.store-name.changelog.replication.factor 
> and stores.store-name.changelog.topic-level-property are incorrect
> ---------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: SAMZA-737
>                 URL: https://issues.apache.org/jira/browse/SAMZA-737
>             Project: Samza
>          Issue Type: Bug
>          Components: docs
>    Affects Versions: 0.9.0
>            Reporter: Carl Laird
>            Priority: Minor
>
> In the following configuration doc:
> http://samza.apache.org/learn/documentation/0.9/jobs/configuration-table.html
> The properties stores.store-name.changelog.replication.factor and 
> stores.store-name.changelog.topic-level-property
> should be stores.store-name.changelog.kafka.replication.factor and 
> stores.store-name.changelog.kafka.topic-level-property



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to