{"action":"created","issue":{"url":"https://api.github.com/repos/apache/spark/issues/5936","labels_url":"https://api.github.com/repos/apache/spark/issues/5936/labels{/name}","comments_url":"https://api.github.com/repos/apache/spark/issues/5936/comments","events_url":"https://api.github.com/repos/apache/spark/issues/5936/events","html_url":"https://github.com/apache/spark/pull/5936","id":73548209,"number":5936,"title":"[SPARK-7396][Streaming][Example] Update KafkaWordCountProducer to use new Producer API","user":{"login":"jerryshao","id":850797,"avatar_url":"https://avatars.githubusercontent.com/u/850797?v=3","gravatar_id":"","url":"https://api.github.com/users/jerryshao","html_url":"https://github.com/jerryshao","followers_url":"https://api.github.com/users/jerryshao/followers","following_url":"https://api.github.com/users/jerryshao/following{/other_user}","gists_url":"https://api.github.com/users/jerryshao/gists{/gist_id}","starred_url":"https://api.github.com/users/jerryshao/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jerryshao/subscriptions","organizations_url":"https://api.github.com/users/jerryshao/orgs","repos_url":"https://api.github.com/users/jerryshao/repos","events_url":"https://api.github.com/users/jerryshao/events{/privacy}","received_events_url":"https://api.github.com/users/jerryshao/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":3,"created_at":"2015-05-06T07:57:56Z","updated_at":"2015-05-06T08:03:58Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/spark/pulls/5936","html_url":"https://github.com/apache/spark/pull/5936","diff_url":"https://github.com/apache/spark/pull/5936.diff","patch_url":"https://github.com/apache/spark/pull/5936.patch"},"body":"Otherwise it will throw exception:\r\n\r\n```\r\nException in thread \"main\" kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.\r\n\tat kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)\r\n\tat kafka.producer.Producer.send(Producer.scala:77)\r\n\tat org.apache.spark.examples.streaming.KafkaWordCountProducer$.main(KafkaWordCount.scala:96)\r\n\tat org.apache.spark.examples.streaming.KafkaWordCountProducer.main(KafkaWordCount.scala)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n\tat java.lang.reflect.Method.invoke(Method.java:606)\r\n\tat org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:623)\r\n\tat org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:169)\r\n\tat org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:192)\r\n\tat org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:111)\r\n\tat org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)\r\n```"},"comment":{"url":"https://api.github.com/repos/apache/spark/issues/comments/99366328","html_url":"https://github.com/apache/spark/pull/5936#issuecomment-99366328","issue_url":"https://api.github.com/repos/apache/spark/issues/5936","id":99366328,"user":{"login":"SparkQA","id":8108735,"avatar_url":"https://avatars.githubusercontent.com/u/8108735?v=3","gravatar_id":"","url":"https://api.github.com/users/SparkQA","html_url":"https://github.com/SparkQA","followers_url":"https://api.github.com/users/SparkQA/followers","following_url":"https://api.github.com/users/SparkQA/following{/other_user}","gists_url":"https://api.github.com/users/SparkQA/gists{/gist_id}","starred_url":"https://api.github.com/users/SparkQA/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/SparkQA/subscriptions","organizations_url":"https://api.github.com/users/SparkQA/orgs","repos_url":"https://api.github.com/users/SparkQA/repos","events_url":"https://api.github.com/users/SparkQA/events{/privacy}","received_events_url":"https://api.github.com/users/SparkQA/received_events","type":"User","site_admin":false},"created_at":"2015-05-06T08:03:58Z","updated_at":"2015-05-06T08:03:58Z","body":"  [Test build #31965 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/31965/consoleFull) for   PR 5936 at commit [`270bbe2`](https://github.com/apache/spark/commit/270bbe2d7860d07117987dc67fec7f7483dd55b3)."}}