@Sumit Chauhan It looks like metadata.broker.list is deprecated and we need to use bootstrap.servers instead. I found below github code snippet where it says metadata.broker.list is deprecated https://github.com/apache/samza/blob/master/samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala val bootsrapServers = {
if(properties.containsKey("metadata.broker.list"))
warn("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")
Option(properties.get("bootstrap.servers"))
.getOrElse(throw new SamzaException("No bootstrap servers defined in config for %s." format systemName))
.asInstanceOf[String] bootstrap.servers http://kafka.apache.org/documentation.html metadata.broker.list http://kafka.apache.org/081/configuration.html Hope this information helps!
... View more
