-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/50451/
-----------------------------------------------------------

Review request for samza, Navina Ramesh and Yi Pan (Data Infrastructure).


Repository: samza


Description
-------

SAMZA-981: Set consistent Kafka clientId for a job instance


Diffs
-----

  samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala 
18225118ee5a3c70898274b28fe4ff0a11b55a12 
  samza-kafka/src/main/scala/org/apache/samza/config/RegExTopicGenerator.scala 
78467bf1298653242e0b14d810e53a92a2ed139f 
  
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.scala
 b37375360bcad8e3333089d95e8e3da63a1b9aab 
  samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala 
a25ba620a58153b47059fbc11ae067f863e7c3cd 
  samza-kafka/src/test/scala/org/apache/samza/config/TestKafkaConfig.scala 
c4a83f60cf049e6fd65f940b69674895d07ab871 
  
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemConsumer.scala
 ece0359d1a31e65113f4832dd3baddb788cecef4 

Diff: https://reviews.apache.org/r/50451/diff/


Testing
-------

gradle build & tests


Thanks,

Xinyu Liu

Reply via email to