> On Jan. 23, 2015, 7:01 p.m., Chris Riccomini wrote: > > samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala, line > > 196 > > <https://reviews.apache.org/r/29899/diff/4/?file=831256#file831256line196> > > > > Stronger message that forces them to read the docs: > > > > "Kafka producer configuration contains 'metadata.broker.list'. This > > configuration is deprecated . Samza has been upgraded to use Kafka's new > > producer API. Please update your configurations based on the documentation > > at http://kafka.apache.org/documentation.html#newproducerconfigs";
Ok. Makes sense. > On Jan. 23, 2015, 7:01 p.m., Chris Riccomini wrote: > > samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala, line > > 194 > > <https://reviews.apache.org/r/29899/diff/4/?file=831256#file831256line194> > > > > Should rename this to bootstrapServers Sure. > On Jan. 23, 2015, 7:01 p.m., Chris Riccomini wrote: > > samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducerMetrics.scala, > > line 31 > > <https://reviews.apache.org/r/29899/diff/4/?file=831259#file831259line31> > > > > Can you do per-var javadocs? > > > > /* > > * Tracks the number of calls made to send in KafkaSystemProducer > > */ > > val sends = newCounter("producer-sends") > > > > /* > > * Tracks the number of calls made to flush in KafkaSystemProducer > > */ > > val flushes = newCounter("flushes") Ok > On Jan. 23, 2015, 7:01 p.m., Chris Riccomini wrote: > > samza-test/src/main/config/negate-number.properties, line 47 > > <https://reviews.apache.org/r/29899/diff/4/?file=831268#file831268line47> > > > > Can you do a quick grep through the code base, adn make sure no other > > configs need to be changed? I already did a grep for this config and replaced them. - Navina ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29899/#review69437 ----------------------------------------------------------- On Jan. 23, 2015, 12:42 a.m., Navina Ramesh wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/29899/ > ----------------------------------------------------------- > > (Updated Jan. 23, 2015, 12:42 a.m.) > > > Review request for samza, Chris Riccomini, Guozhang Wang, and Jay Kreps. > > > Bugs: SAMZA-227 > https://issues.apache.org/jira/browse/SAMZA-227 > > > Repository: samza > > > Description > ------- > > Modified logic in KafkaSystemProducer for send & flush based on the behavior > of the new java-based Kafka producer API > Added "MockKafkaProducer" in Samza layer to mock out the buffering behavior > provided by Kafka producer. The MockProducer exposed by Kafka does not > provide sufficient control for writing unit tests. > Producer config for Kafka is unified in "KafkaProducerConfig" with > appropriate default values. These can be overriden while instantiating the > producer config. > > > Diffs > ----- > > build.gradle 7a40ad4ae916610186848c06c4577e7067de98ee > docs/learn/documentation/versioned/jobs/configuration-table.html > 4ccc0e70b0817c1301fb82d0aa1efeff2575eea2 > gradle/dependency-versions.gradle 44dd42603e93788562fd64c68312570cee71a2aa > > samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala > 1d5627d0c561a0be6b48ee307b755958e62b783e > > samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala > f2defbd39708e959edb1d6674e542b5bc9e02666 > samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala > e57b8ba1e09765774314ec469645b5d0bbde060f > > samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala > 4506ea367eec4e40da45feee777ba73069025a4c > > samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala > a0e1ccbfe9dc4fd26ca6b30fc2d1348fb7d007e4 > > samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducerMetrics.scala > 7e1383f9c10a9231b3e41f2be54d750d3d2c6523 > samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala > f1b7511775703775eaa5172d7da88d302a89aa2e > > samza-kafka/src/test/scala/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.scala > 553d6b4d6ffe21f4a92c8c347e835d95d71b5863 > samza-kafka/src/test/scala/org/apache/samza/config/TestKafkaConfig.scala > 0e1c38e5d68f2f3e42ecdb58297a11ff5d29374d > > samza-kafka/src/test/scala/org/apache/samza/system/kafka/MockKafkaProducer.java > PRE-CREATION > > samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala > c759a7bea7b67714eaa90a97f828079f26acbca4 > > samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala > 8067cbf78214d3c01b7f915d8810b10de57fe6a3 > > samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala > 72b36f774b2b8845539f26fc592244353cf300cd > samza-kafka/src/test/scala/org/apache/samza/utils/TestUtils.java > PRE-CREATION > samza-test/src/main/config/negate-number.properties > 4989b279a22ffd8acdb2c31ca4813f6768edc75b > > samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala > ca25258217e5ebc44b34fbc4d69ecb28c81df618 > > Diff: https://reviews.apache.org/r/29899/diff/ > > > Testing > ------- > > ./gradlew clean build - SUCCESSFUL > > > Thanks, > > Navina Ramesh > >
