{"action":"created","issue":{"url":"https://api.github.com/repos/apache/flink/issues/2231","repository_url":"https://api.github.com/repos/apache/flink","labels_url":"https://api.github.com/repos/apache/flink/issues/2231/labels{/name}","comments_url":"https://api.github.com/repos/apache/flink/issues/2231/comments","events_url":"https://api.github.com/repos/apache/flink/issues/2231/events","html_url":"https://github.com/apache/flink/pull/2231","id":165160114,"number":2231,"title":"[FLINK-4035] Bump Kafka producer in Kafka sink to Kafka 0.10.0.0","user":{"login":"radekg","id":62946,"avatar_url":"https://avatars.githubusercontent.com/u/62946?v=3","gravatar_id":"","url":"https://api.github.com/users/radekg","html_url":"https://github.com/radekg","followers_url":"https://api.github.com/users/radekg/followers","following_url":"https://api.github.com/users/radekg/following{/other_user}","gists_url":"https://api.github.com/users/radekg/gists{/gist_id}","starred_url":"https://api.github.com/users/radekg/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/radekg/subscriptions","organizations_url":"https://api.github.com/users/radekg/orgs","repos_url":"https://api.github.com/users/radekg/repos","events_url":"https://api.github.com/users/radekg/events{/privacy}","received_events_url":"https://api.github.com/users/radekg/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":12,"created_at":"2016-07-12T19:28:16Z","updated_at":"2016-07-23T03:46:01Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/apache/flink/pulls/2231","html_url":"https://github.com/apache/flink/pull/2231","diff_url":"https://github.com/apache/flink/pull/2231.diff","patch_url":"https://github.com/apache/flink/pull/2231.patch"},"body":"Hi everyone,\r\n\r\nAt The Weather Company we bumped into a problem while trying to use Flink with Kafka 0.10.x. This PR introduces the support for `FlinkKafkaConsumer010` and `FlinkKafkaProducer010`. Unit test coverage is provided and `mvn clean verify` passes.\r\n\r\nThe output is below:\r\n\r\n```\r\n[INFO] ------------------------------------------------------------------------\r\n[INFO] Reactor Summary:\r\n[INFO]\r\n[INFO] force-shading ...................................... SUCCESS [  1.311 s]\r\n[INFO] flink .............................................. SUCCESS [  2.939 s]\r\n[INFO] flink-annotations .................................. SUCCESS [  1.476 s]\r\n[INFO] flink-shaded-hadoop ................................ SUCCESS [  0.152 s]\r\n[INFO] flink-shaded-hadoop2 ............................... SUCCESS [  7.065 s]\r\n[INFO] flink-shaded-include-yarn-tests .................... SUCCESS [  8.543 s]\r\n[INFO] flink-shaded-curator ............................... SUCCESS [  0.112 s]\r\n[INFO] flink-shaded-curator-recipes ....................... SUCCESS [  1.080 s]\r\n[INFO] flink-shaded-curator-test .......................... SUCCESS [  0.210 s]\r\n[INFO] flink-test-utils-parent ............................ SUCCESS [  0.126 s]\r\n[INFO] flink-test-utils-junit ............................. SUCCESS [  2.019 s]\r\n[INFO] flink-core ......................................... SUCCESS [ 34.501 s]\r\n[INFO] flink-java ......................................... SUCCESS [ 26.266 s]\r\n[INFO] flink-runtime ...................................... SUCCESS [04:57 min]\r\n[INFO] flink-optimizer .................................... SUCCESS [  7.914 s]\r\n[INFO] flink-clients ...................................... SUCCESS [  6.537 s]\r\n[INFO] flink-streaming-java ............................... SUCCESS [ 37.732 s]\r\n[INFO] flink-test-utils ................................... SUCCESS [  6.166 s]\r\n[INFO] flink-scala ........................................ SUCCESS [ 24.626 s]\r\n[INFO] flink-runtime-web .................................. SUCCESS [ 12.831 s]\r\n[INFO] flink-examples ..................................... SUCCESS [  1.123 s]\r\n[INFO] flink-examples-batch ............................... SUCCESS [ 11.919 s]\r\n[INFO] flink-contrib ...................................... SUCCESS [  0.096 s]\r\n[INFO] flink-statebackend-rocksdb ......................... SUCCESS [  7.770 s]\r\n[INFO] flink-tests ........................................ SUCCESS [06:22 min]\r\n[INFO] flink-streaming-scala .............................. SUCCESS [ 26.831 s]\r\n[INFO] flink-streaming-connectors ......................... SUCCESS [  0.100 s]\r\n[INFO] flink-connector-flume .............................. SUCCESS [  2.425 s]\r\n[INFO] flink-libraries .................................... SUCCESS [  0.084 s]\r\n[INFO] flink-table ........................................ SUCCESS [02:02 min]\r\n[INFO] flink-connector-kafka-base ......................... SUCCESS [  4.604 s]\r\n[INFO] flink-connector-kafka-0.8 .......................... SUCCESS [02:01 min]\r\n[INFO] flink-connector-kafka-0.9 .......................... SUCCESS [02:38 min]\r\n[INFO] flink-connector-kafka-0.10 ......................... SUCCESS [02:04 min]\r\n[INFO] flink-connector-elasticsearch ...................... SUCCESS [ 19.310 s]\r\n[INFO] flink-connector-elasticsearch2 ..................... SUCCESS [ 17.086 s]\r\n[INFO] flink-connector-rabbitmq ........................... SUCCESS [  2.885 s]\r\n[INFO] flink-connector-twitter ............................ SUCCESS [  2.649 s]\r\n[INFO] flink-connector-nifi ............................... SUCCESS [  1.339 s]\r\n[INFO] flink-connector-cassandra .......................... SUCCESS [01:21 min]\r\n[INFO] flink-connector-redis .............................. SUCCESS [  5.738 s]\r\n[INFO] flink-connector-filesystem ......................... SUCCESS [ 24.871 s]\r\n[INFO] flink-batch-connectors ............................. SUCCESS [  0.103 s]\r\n[INFO] flink-avro ......................................... SUCCESS [  9.788 s]\r\n[INFO] flink-jdbc ......................................... SUCCESS [  4.839 s]\r\n[INFO] flink-hadoop-compatibility ......................... SUCCESS [ 10.026 s]\r\n[INFO] flink-hbase ........................................ SUCCESS [  2.938 s]\r\n[INFO] flink-hcatalog ..................................... SUCCESS [  5.383 s]\r\n[INFO] flink-examples-streaming ........................... SUCCESS [ 24.339 s]\r\n[INFO] flink-gelly ........................................ SUCCESS [ 40.416 s]\r\n[INFO] flink-gelly-scala .................................. SUCCESS [ 29.050 s]\r\n[INFO] flink-gelly-examples ............................... SUCCESS [ 21.418 s]\r\n[INFO] flink-python ....................................... SUCCESS [ 58.016 s]\r\n[INFO] flink-ml ........................................... SUCCESS [ 57.270 s]\r\n[INFO] flink-cep .......................................... SUCCESS [  6.984 s]\r\n[INFO] flink-cep-scala .................................... SUCCESS [  8.521 s]\r\n[INFO] flink-scala-shell .................................. SUCCESS [03:28 min]\r\n[INFO] flink-quickstart ................................... SUCCESS [  1.248 s]\r\n[INFO] flink-quickstart-java .............................. SUCCESS [  0.610 s]\r\n[INFO] flink-quickstart-scala ............................. SUCCESS [  0.237 s]\r\n[INFO] flink-storm ........................................ SUCCESS [ 14.975 s]\r\n[INFO] flink-storm-examples ............................... SUCCESS [ 37.513 s]\r\n[INFO] flink-streaming-contrib ............................ SUCCESS [  8.452 s]\r\n[INFO] flink-tweet-inputformat ............................ SUCCESS [  3.075 s]\r\n[INFO] flink-operator-stats ............................... SUCCESS [  6.521 s]\r\n[INFO] flink-connector-wikiedits .......................... SUCCESS [ 18.022 s]\r\n[INFO] flink-yarn ......................................... SUCCESS [  7.539 s]\r\n[INFO] flink-dist ......................................... SUCCESS [ 11.453 s]\r\n[INFO] flink-metrics ...................................... SUCCESS [  0.101 s]\r\n[INFO] flink-metrics-dropwizard ........................... SUCCESS [  2.699 s]\r\n[INFO] flink-metrics-ganglia .............................. SUCCESS [  1.320 s]\r\n[INFO] flink-metrics-graphite ............................. SUCCESS [  1.188 s]\r\n[INFO] flink-metrics-statsd ............................... SUCCESS [  2.271 s]\r\n[INFO] flink-fs-tests ..................................... SUCCESS [ 27.916 s]\r\n[INFO] flink-java8 ........................................ SUCCESS [ 12.209 s]\r\n[INFO] ------------------------------------------------------------------------\r\n[INFO] BUILD SUCCESS\r\n[INFO] ------------------------------------------------------------------------\r\n[INFO] Total time: 37:24 min\r\n[INFO] Finished at: 2016-07-12T15:18:39-04:00\r\n[INFO] Final Memory: 234M/1833M\r\n[INFO] ------------------------------------------------------------------------\r\n```\r\n\r\nThe only thing not provided right in this moment in time, is the documentation updates. Not sure how to take on that one, some guidance would be appreciated.\r\n\r\nWhat would be the best way to proceed with the contribution?"},"comment":{"url":"https://api.github.com/repos/apache/flink/issues/comments/234697068","html_url":"https://github.com/apache/flink/pull/2231#issuecomment-234697068","issue_url":"https://api.github.com/repos/apache/flink/issues/2231","id":234697068,"user":{"login":"tzulitai","id":5284370,"avatar_url":"https://avatars.githubusercontent.com/u/5284370?v=3","gravatar_id":"","url":"https://api.github.com/users/tzulitai","html_url":"https://github.com/tzulitai","followers_url":"https://api.github.com/users/tzulitai/followers","following_url":"https://api.github.com/users/tzulitai/following{/other_user}","gists_url":"https://api.github.com/users/tzulitai/gists{/gist_id}","starred_url":"https://api.github.com/users/tzulitai/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/tzulitai/subscriptions","organizations_url":"https://api.github.com/users/tzulitai/orgs","repos_url":"https://api.github.com/users/tzulitai/repos","events_url":"https://api.github.com/users/tzulitai/events{/privacy}","received_events_url":"https://api.github.com/users/tzulitai/received_events","type":"User","site_admin":false},"created_at":"2016-07-23T03:46:01Z","updated_at":"2016-07-23T03:46:01Z","body":"@radekg Thank you for the quick fix. I hope to find time over the weekend to test + review this, if not than early next week :)"}}
{"actor":{"display_login":"tzulitai"}}