[jira] [Commented] (KAFKA-2452) enable new consumer in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943728#comment-14943728 ] Jiangjie Qin commented on KAFKA-2452: - [~zhoux_samuel] bin/kafka-consumer-offset-check.sh should work.

[GitHub] kafka pull request: HOTFIX: Persistent store in ProcessorStateMana...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/276 HOTFIX: Persistent store in ProcessorStateManagerTest @ymatsuda @junrao Could you take a quick look? The current unit test is failing on this. You can merge this pull request into a Git

Re: Should the KafkaProducer callback get the record batch?

Gwen, It looks there are two requirements here: 1. Know which message failed. 2. Know which record batch failed. i.e. which messages fail together. The current callback interface can easily support (1) - user can simply construct here own callback which store the message in it. Do you mean we

[jira] [Commented] (KAFKA-2580) Kafka Broker keeps file handles open for all log files (even if its not written to/read from)

[ https://issues.apache.org/jira/browse/KAFKA-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943698#comment-14943698 ] Joel Koshy commented on KAFKA-2580: --- I was wondering if we can do with something much simpler -

[jira] [Commented] (KAFKA-2587) Transient test failure: `SimpleAclAuthorizerTest`

[ https://issues.apache.org/jira/browse/KAFKA-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943705#comment-14943705 ] Jun Rao commented on KAFKA-2587: [~parth.brahmbhatt], the issue for the above test failure can be due to

[GitHub] kafka pull request: KAFKA-2604; Remove `completeAll` and improve t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/272 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-2452) enable new consumer in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943834#comment-14943834 ] Samuel Zhou commented on KAFKA-2452: Looks like it can't find zookeeper path for the topic in the

[jira] [Updated] (KAFKA-2604) Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

[ https://issues.apache.org/jira/browse/KAFKA-2604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2604: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request: Kafka-2587: Only notification handler will upd...

GitHub user Parth-Brahmbhatt opened a pull request: https://github.com/apache/kafka/pull/277 Kafka-2587: Only notification handler will update the cache and all verifications will use waitUntilTrue. You can merge this pull request into a Git repository by running: $ git

Re: Review Request 36858: Patch for KAFKA-2120

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

[jira] [Commented] (KAFKA-2452) enable new consumer in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943833#comment-14943833 ] Samuel Zhou commented on KAFKA-2452: Looks like it can't find zookeeper path for the topic in the

[jira] [Commented] (KAFKA-2587) Transient test failure: `SimpleAclAuthorizerTest`

[ https://issues.apache.org/jira/browse/KAFKA-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943792#comment-14943792 ] Parth Brahmbhatt commented on KAFKA-2587: - https://github.com/apache/kafka/pull/277/files >

[jira] [Issue Comment Deleted] (KAFKA-2452) enable new consumer in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-2452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samuel Zhou updated KAFKA-2452: --- Comment: was deleted (was: Looks like it can't find zookeeper path for the topic in the consumer

[jira] [Commented] (KAFKA-2604) Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

[ https://issues.apache.org/jira/browse/KAFKA-2604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943837#comment-14943837 ] ASF GitHub Bot commented on KAFKA-2604: --- Github user asfgit closed the pull request at:

[jira] [Created] (KAFKA-2611) Document MirrorMaker

Gwen Shapira created KAFKA-2611: --- Summary: Document MirrorMaker Key: KAFKA-2611 URL: https://issues.apache.org/jira/browse/KAFKA-2611 Project: Kafka Issue Type: Bug Reporter: Gwen

Build failed in Jenkins: kafka-trunk-jdk8 #2

See Changes: [wangguoz] KAFKA-2604; Remove `completeAll` and improve timeout passed to -- [...truncated 5936 lines...] org.apache.kafka.clients.consumer.internals.CoordinatorTest >

Re: Review Request 36858: Patch for KAFKA-2120

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

Build failed in Jenkins: kafka-trunk-jdk7 #659

See Changes: [wangguoz] KAFKA-2604; Remove `completeAll` and improve timeout passed to -- [...truncated 3617 lines...] org.apache.kafka.common.record.RecordTest > testChecksum[61] PASSED

[jira] [Commented] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943951#comment-14943951 ] Ismael Juma commented on KAFKA-2566: We now have a summary of failed tests without having to look at

Re: Review Request 36858: Patch for KAFKA-2120

> On Oct. 5, 2015, 6:51 p.m., Guozhang Wang wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 427 > > > > > > One minor thing: could you remove this comment? I had

Re: Review Request 36858: Patch for KAFKA-2120

> On Oct. 5, 2015, 8:34 p.m., Joel Koshy wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 427 > > > > > > LGTM - Guozhang, can you do a trivial commit to remove it?

[GitHub] kafka pull request: KAFKA-2527; System Test for Quotas in Ducktape

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/275 KAFKA-2527; System Test for Quotas in Ducktape @granders Can you take a look at this quota system test? You can merge this pull request into a Git repository by running: $ git pull

Re: Should the KafkaProducer callback get the record batch?

I with with Ewen here. If users want to access the ProducerRecord info in the callback they can create their callbacks to include those info and pay their own costs as for object construction / etc; the RecordBatch is considered internal in Producer and not exposed to users by design. Guozhang

Re: Should the KafkaProducer callback get the record batch?

ok, I'm convinced and will go with new callback object per send request. On Mon, Oct 5, 2015 at 5:50 PM, Guozhang Wang wrote: > I with with Ewen here. If users want to access the ProducerRecord info in > the callback they can create their callbacks to include those info and

[GitHub] kafka pull request: TRIVIAL: remove TODO in KafkaConsumer after KA...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/278 TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120 You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka TL-KafkaConsumer

[GitHub] kafka pull request: TRIVIAL: remove TODO in KafkaConsumer after KA...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/278 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944043#comment-14944043 ] Ismael Juma commented on KAFKA-1894: `NetworkClient.completeAll` has thankfully been removed, so

Kafka KIP meeting Oct 6 at 11:00am PST

Hi, Everyone, We will have a Kafka KIP meeting tomorrow at 11:00am PST. If you plan to attend but haven't received an invite, please let me know. The following is the agenda. Agenda: 1. KIP-32: Add CreateTime and LogAppendTime to Kafka message 2. KIP-33: Add a time based log index 3. KIP-35: Add

Build failed in Jenkins: kafka-trunk-jdk7 #660

See Changes: [wangguoz] HOTFIX: Persistent store in ProcessorStateManagerTest [wangguoz] TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120 -- [...truncated 1548 lines...]

Build failed in Jenkins: kafka-trunk-jdk8 #3

See Changes: [wangguoz] HOTFIX: Persistent store in ProcessorStateManagerTest [wangguoz] TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120 -- [...truncated 2045 lines...]

[GitHub] kafka pull request: Transient exception

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/279 Transient exception Transient exception handling. You can merge this pull request into a Git repository by running: $ git pull https://github.com/confluentinc/kafka transient-exception

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944047#comment-14944047 ] ASF GitHub Bot commented on KAFKA-2120: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944042#comment-14944042 ] ASF GitHub Bot commented on KAFKA-2120: --- GitHub user guozhangwang opened a pull request:

[jira] [Assigned] (KAFKA-2391) Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

[ https://issues.apache.org/jira/browse/KAFKA-2391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman reassigned KAFKA-2391: --- Assignee: Onur Karaman (was: Mayuresh Gharat) > Blocking call such as position(),

Re: Review Request 36858: Patch for KAFKA-2120

> On Oct. 5, 2015, 6:51 p.m., Guozhang Wang wrote: > > clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, > > line 427 > > > > > > One minor thing: could you remove this comment? > >

Re: Review Request 36858: Patch for KAFKA-2120

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

[GitHub] kafka pull request: HOTFIX: Persistent store in ProcessorStateMana...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/276 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-2587) Transient test failure: `SimpleAclAuthorizerTest`

[ https://issues.apache.org/jira/browse/KAFKA-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944171#comment-14944171 ] Jun Rao commented on KAFKA-2587: As for seeing consistent view in ZK, I am not 100% sure about some of the

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944398#comment-14944398 ] Jiangjie Qin commented on KAFKA-2477: - [~junrao] I'll fix the nexOffsetMetadata in the patch. Would

Re: KAFKA-2364 migrate docs from SVN to git

Hi Gwen, Kafka site is updated to use Git repo. We can now push any site changes to git web site repo. 1) "Contributing website changes" wiki page: https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Website+Documentation+Changes 2) "Website update process" added to Release Process

[jira] [Updated] (KAFKA-2573) Mirror maker system test hangs and eventually fails

[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2573: - Reviewer: Guozhang Wang > Mirror maker system test hangs and eventually fails >

[jira] [Commented] (KAFKA-2573) Mirror maker system test hangs and eventually fails

[ https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14944432#comment-14944432 ] Ewen Cheslack-Postava commented on KAFKA-2573: -- Agreed with [~lindong] that the tools itself

[jira] [Updated] (KAFKA-2581) Run all existing ducktape tests with SSL-enabled clients and brokers

[ https://issues.apache.org/jira/browse/KAFKA-2581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2581: - Reviewer: Guozhang Wang > Run all existing ducktape tests with SSL-enabled

[jira] [Updated] (KAFKA-2527) System Test for Quotas in Ducktape

[ https://issues.apache.org/jira/browse/KAFKA-2527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2527: - Reviewer: Guozhang Wang > System Test for Quotas in Ducktape >

Re: [DISCUSS] KIP-32 - Add CreateTime and LogAppendTime to Kafka message

Bumping up this thread although most of the discussion were on the discussion thread of KIP-31 :) I just updated the KIP page to add detailed solution for the option (Option 3) that does not expose the LogAppendTime to user.

[jira] [Comment Edited] (KAFKA-2610) Metrics for SSL handshake

[ https://issues.apache.org/jira/browse/KAFKA-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943172#comment-14943172 ] Ismael Juma edited comment on KAFKA-2610 at 10/5/15 10:16 AM: -- cc [~junrao]

[jira] [Commented] (KAFKA-2610) Metrics for SSL handshake

[ https://issues.apache.org/jira/browse/KAFKA-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943172#comment-14943172 ] Ismael Juma commented on KAFKA-2610: cc @junrao > Metrics for SSL handshake >

[jira] [Updated] (KAFKA-2610) Metrics for SSL handshake

[ https://issues.apache.org/jira/browse/KAFKA-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2610: --- Description: It would be useful to report some metrics on SSL handshakes to make sure that they are

[jira] [Created] (KAFKA-2610) Metrics for SSL handshake

Ismael Juma created KAFKA-2610: -- Summary: Metrics for SSL handshake Key: KAFKA-2610 URL: https://issues.apache.org/jira/browse/KAFKA-2610 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943214#comment-14943214 ] Ismael Juma commented on KAFKA-2584: [~jjkoshy], can you please elaborate on how you would want the

[jira] [Commented] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943219#comment-14943219 ] Ismael Juma commented on KAFKA-2584: Thinking about it some more, it seems like one would want a

[jira] [Comment Edited] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943219#comment-14943219 ] Ismael Juma edited comment on KAFKA-2584 at 10/5/15 10:53 AM: -- Thinking about

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943386#comment-14943386 ] Rajini Sivaram commented on KAFKA-2609: --- Another issue to test is the inconsistency in the behaviour

[jira] [Comment Edited] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943433#comment-14943433 ] Flavio Junqueira edited comment on KAFKA-2566 at 10/5/15 2:41 PM: -- I have

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943474#comment-14943474 ] Rajini Sivaram commented on KAFKA-2609: --- [~ijuma] We dont have a requirement to support SSL

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943481#comment-14943481 ] Ismael Juma commented on KAFKA-2609: If it is a useful feature to support longer term, then it would

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943401#comment-14943401 ] Ismael Juma commented on KAFKA-2609: [~rsivaram], thanks for filing this. One question I have is

Build failed in Jenkins: kafka-trunk-jdk8 #1

See -- [...truncated 2045 lines...] kafka.api.ConsumerTest > testUnsubscribeTopic PASSED kafka.integration.PrimitiveApiTest > testProduceAndMultiFetch PASSED kafka.integration.SslTopicMetadataTest >

[jira] [Commented] (KAFKA-2587) Transient test failure: `SimpleAclAuthorizerTest`

[ https://issues.apache.org/jira/browse/KAFKA-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943378#comment-14943378 ] Ismael Juma commented on KAFKA-2587: Another failure, output looks different:

[jira] [Comment Edited] (KAFKA-2587) Transient test failure: `SimpleAclAuthorizerTest`

[ https://issues.apache.org/jira/browse/KAFKA-2587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943378#comment-14943378 ] Ismael Juma edited comment on KAFKA-2587 at 10/5/15 1:49 PM: - Another failure,

[jira] [Commented] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943433#comment-14943433 ] Flavio Junqueira commented on KAFKA-2566: - I have changed the jenkins configuration with

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943500#comment-14943500 ] Rajini Sivaram commented on KAFKA-2609: --- Periodic renegotiation is typically used to refresh

[jira] [Commented] (KAFKA-2584) SecurityProtocol enum validation should be removed or relaxed for non-config usages

[ https://issues.apache.org/jira/browse/KAFKA-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943694#comment-14943694 ] Joel Koshy commented on KAFKA-2584: --- Here is a quick summary of the patch we ended up applying at

[jira] [Assigned] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-2566: --- Assignee: Flavio Junqueira > Improve Jenkins set-up > -- > >

[jira] [Updated] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2566: Component/s: build > Improve Jenkins set-up > -- > >

[jira] [Commented] (KAFKA-1686) Implement SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-1686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943620#comment-14943620 ] Jun Rao commented on KAFKA-1686: [~sriharsha], any updates on the PR? Thanks. > Implement SASL/Kerberos >

[jira] [Commented] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943539#comment-14943539 ] Ismael Juma commented on KAFKA-2609: Interesting, good to know. Regarding the question about producer

[GitHub] kafka-site pull request: updated contributing.html

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka-site/pull/1 updated contributing.html updated "contributing website changes" section. You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka-site

[jira] [Commented] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943651#comment-14943651 ] Guozhang Wang commented on KAFKA-2566: -- Verified all builds are configured and working now. >

Re: Should the KafkaProducer callback get the record batch?

+1 Ewen. Currently the while creating the RecordBatch we extract the key and value and add it to the batch. At a very high level, we will have to extract the key and Value (minimum atleast) from each record in the RecordBatch, create a wrapper with the exception,the key and the value and add it

[jira] [Resolved] (KAFKA-2566) Improve Jenkins set-up

[ https://issues.apache.org/jira/browse/KAFKA-2566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira resolved KAFKA-2566. - Resolution: Fixed Reviewer: Guozhang Wang All builds working as expected. >

[jira] [Updated] (KAFKA-2604) Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

[ https://issues.apache.org/jira/browse/KAFKA-2604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2604: - Reviewer: Guozhang Wang (was: Jason Gustafson) > Remove `completeAll` and

[jira] [Commented] (KAFKA-2604) Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

[ https://issues.apache.org/jira/browse/KAFKA-2604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943669#comment-14943669 ] Ewen Cheslack-Postava commented on KAFKA-2604: -- [~ijuma] Changed the reviewer to a committer