[jira] [Commented] (KAFKA-5647) Use async ZookeeperClient for Admin operations

[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114219#comment-16114219 ] Manikumar commented on KAFKA-5647: -- [~ijuma] [~onurkaraman] Are we going to refactor Zk

[jira] [Commented] (KAFKA-5461) KIP-168: Add GlobalTopicCount metric per cluster

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

[jira] [Updated] (KAFKA-5461) KIP-168: Add GlobalTopicCount metric per cluster

[ https://issues.apache.org/jira/browse/KAFKA-5461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5461: --- Labels: kip (was: ) > KIP-168: Add GlobalTopicCount metric per cluster >

[jira] [Comment Edited] (KAFKA-5647) Use async ZookeeperClient for Admin operations

[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114219#comment-16114219 ] Manikumar edited comment on KAFKA-5647 at 8/4/17 10:50 AM: --- [~ij

[jira] [Updated] (KAFKA-5700) producer missed header information when splitting batches

[ https://issues.apache.org/jira/browse/KAFKA-5700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5700: --- Priority: Critical (was: Major) > producer missed header information when splitting batches > ---

[jira] [Updated] (KAFKA-5700) producer missed header information when splitting batches

[ https://issues.apache.org/jira/browse/KAFKA-5700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5700: --- Labels: reliability (was: ) > producer missed header information when splitting batches > ---

[jira] [Commented] (KAFKA-5647) Use async ZookeeperClient for Admin operations

[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114241#comment-16114241 ] Ismael Juma commented on KAFKA-5647: [~omkreddy], we will refactor the code incrementa

[jira] [Updated] (KAFKA-5700) producer missed header information when splitting batches

[ https://issues.apache.org/jira/browse/KAFKA-5700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5700: --- Fix Version/s: 0.11.0.1 > producer missed header information when splitting batches >

[jira] [Commented] (KAFKA-5599) ConsoleConsumer : --new-consumer option as deprecated

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

[jira] [Commented] (KAFKA-5619) Make --new-consumer option as deprecated in all tools

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

[jira] [Commented] (KAFKA-5588) ConsoleConsumer : uselss --new-consumer option

[ https://issues.apache.org/jira/browse/KAFKA-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114281#comment-16114281 ] ASF GitHub Bot commented on KAFKA-5588: --- Github user ppatierno closed the pull reque

[jira] [Commented] (KAFKA-5388) Replace zkClient.subscribe*Changes method with an equivalent zkUtils method

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

[jira] [Resolved] (KAFKA-5102) Refactor core components to use zkUtils methods instead of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar resolved KAFKA-5102. -- Resolution: Fixed > Refactor core components to use zkUtils methods instead of zkUtils.zkClient

[jira] [Created] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails

Eno Thereska created KAFKA-5701: --- Summary: Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails Key: KAFKA-5701 URL: https://issues.apache.org/jira/browse/KAFKA-5701 Project: Kafka

[jira] [Commented] (KAFKA-4039) Exit Strategy: using exceptions instead of inline invocation of exit/halt

[ https://issues.apache.org/jira/browse/KAFKA-4039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114442#comment-16114442 ] ASF GitHub Bot commented on KAFKA-4039: --- Github user maysamyabandeh closed the pull

[jira] [Created] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

Damian Guy created KAFKA-5702: - Summary: Refactor StreamThread to separate concerns and enable better testability Key: KAFKA-5702 URL: https://issues.apache.org/jira/browse/KAFKA-5702 Project: Kafka

[jira] [Assigned] (KAFKA-5701) Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails

[ https://issues.apache.org/jira/browse/KAFKA-5701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5701: -- Assignee: Bill Bejeck > Unit test shouldTogglePrepareForBulkLoadDuringRestoreCalls fails >

[jira] [Commented] (KAFKA-5702) Refactor StreamThread to separate concerns and enable better testability

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

[jira] [Updated] (KAFKA-5546) Temporary loss of availability data when the leader is disconnected

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Björn Eriksson updated KAFKA-5546: -- Attachment: (was: kafka-failure-log.txt) > Temporary loss of availability data when the lead

[jira] [Updated] (KAFKA-5546) Temporary loss of availability data when the leader is disconnected

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Björn Eriksson updated KAFKA-5546: -- Affects Version/s: 0.11.0.0 Environment: docker, failing-network Description:

[jira] [Comment Edited] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114563#comment-16114563 ] Paolo Patierno edited comment on KAFKA-5684 at 8/4/17 4:07 PM: -

[jira] [Commented] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor

[ https://issues.apache.org/jira/browse/KAFKA-5684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114563#comment-16114563 ] Paolo Patierno commented on KAFKA-5684: --- Just to add that the {{KStreamPrint}} needs

[jira] [Commented] (KAFKA-5546) Temporary loss of availability data when the leader is disconnected

[ https://issues.apache.org/jira/browse/KAFKA-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114569#comment-16114569 ] Jason Gustafson commented on KAFKA-5546: If you bring the interface down, do open

[jira] [Commented] (KAFKA-5647) Use async ZookeeperClient for Admin operations

[ https://issues.apache.org/jira/browse/KAFKA-5647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114594#comment-16114594 ] Onur Karaman commented on KAFKA-5647: - [~omkreddy] yeah as [~ijuma] said, for now I wo

[jira] [Commented] (KAFKA-5617) Update to the list of third-party clients

[ https://issues.apache.org/jira/browse/KAFKA-5617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114621#comment-16114621 ] Jason Gustafson commented on KAFKA-5617: [~dasch] I've granted you access to edit

[jira] [Commented] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime

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

[jira] [Commented] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

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

[jira] [Assigned] (KAFKA-5644) Transient test failure: ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime

[ https://issues.apache.org/jira/browse/KAFKA-5644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5644: Assignee: Manikumar > Transient test failure: > ResetConsumerGroupOffsetTest.testResetOffsetsToZon

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114678#comment-16114678 ] James Cheng commented on KAFKA-1120: [~onurkaraman], what do you think of Jun's sugges

[jira] [Created] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger

Onur Karaman created KAFKA-5703: --- Summary: allow debug-level logging for RequestChannel's request logger Key: KAFKA-5703 URL: https://issues.apache.org/jira/browse/KAFKA-5703 Project: Kafka Is

[jira] [Commented] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger

[ https://issues.apache.org/jira/browse/KAFKA-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114775#comment-16114775 ] Ismael Juma commented on KAFKA-5703: Fixed in https://github.com/apache/kafka/commit/

[jira] [Resolved] (KAFKA-5703) allow debug-level logging for RequestChannel's request logger

[ https://issues.apache.org/jira/browse/KAFKA-5703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman resolved KAFKA-5703. - Resolution: Fixed Woops. Looks like [~ijuma] already fixed this 3 days ago: 4086db472d08f6dee4d30d

[jira] [Commented] (KAFKA-5681) jarAll does not build all scala versions anymore.

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

[jira] [Commented] (KAFKA-5681) jarAll does not build all scala versions anymore.

[ https://issues.apache.org/jira/browse/KAFKA-5681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114889#comment-16114889 ] Ismael Juma commented on KAFKA-5681: [~becket_qin], `jarAll` only builds for Scala 2.1

[jira] [Commented] (KAFKA-1120) Controller could miss a broker state change

[ https://issues.apache.org/jira/browse/KAFKA-1120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114911#comment-16114911 ] Onur Karaman commented on KAFKA-1120: - [~wushujames] I think Jun's comments and the re

[jira] [Updated] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-5696: - Labels: newbie (was: ) > SourceConnector does not commit offset on reconfiguration >

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114922#comment-16114922 ] Randall Hauch commented on KAFKA-5696: -- One option for the standalone and distributed

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114942#comment-16114942 ] Oleg Kuznetsov commented on KAFKA-5696: --- [~rhauch] Thanks. Do you confirm it could b

[jira] [Commented] (KAFKA-5681) jarAll does not build all scala versions anymore.

[ https://issues.apache.org/jira/browse/KAFKA-5681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16114950#comment-16114950 ] Jiangjie Qin commented on KAFKA-5681: - [~ijuma] The confusion part is that we have alw

[jira] [Created] (KAFKA-5704) Auto topic creation causes failure with older clusters

Ewen Cheslack-Postava created KAFKA-5704: Summary: Auto topic creation causes failure with older clusters Key: KAFKA-5704 URL: https://issues.apache.org/jira/browse/KAFKA-5704 Project: Kafka

[jira] [Created] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation"

Chen He created KAFKA-5705: -- Summary: Kafka Server start failed and reports "unsafe memory access operation" Key: KAFKA-5705 URL: https://issues.apache.org/jira/browse/KAFKA-5705 Project: Kafka Iss

[jira] [Commented] (KAFKA-3408) consumer rebalance fail

[ https://issues.apache.org/jira/browse/KAFKA-3408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115038#comment-16115038 ] Chen He commented on KAFKA-3408: Is this jira still in the latest Kafka? If so, may I work

[jira] [Commented] (KAFKA-2499) kafka-producer-perf-test should use something more realistic than empty byte arrays

[ https://issues.apache.org/jira/browse/KAFKA-2499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115040#comment-16115040 ] Chen He commented on KAFKA-2499: Does Kafka-3554 resolve this problem? User can control th

[jira] [Commented] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-5696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115041#comment-16115041 ] Oleg Kuznetsov commented on KAFKA-5696: --- Is it true that there is a chance of produc

[jira] [Assigned] (KAFKA-5704) Auto topic creation causes failure with older clusters

[ https://issues.apache.org/jira/browse/KAFKA-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-5704: Assignee: Randall Hauch > Auto topic creation causes failure with older clusters >

[jira] [Commented] (KAFKA-5704) Auto topic creation causes failure with older clusters

[ https://issues.apache.org/jira/browse/KAFKA-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115063#comment-16115063 ] Randall Hauch commented on KAFKA-5704: -- As of Kafka 0.11.0.0, the Kafka Connect distr

[jira] [Commented] (KAFKA-5705) Kafka Server start failed and reports "unsafe memory access operation"

[ https://issues.apache.org/jira/browse/KAFKA-5705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115065#comment-16115065 ] Jason Gustafson commented on KAFKA-5705: Seems a dup of KAFKA-5628? Please resolve

[jira] [Commented] (KAFKA-5704) Auto topic creation causes failure with older clusters

[ https://issues.apache.org/jira/browse/KAFKA-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115067#comment-16115067 ] Randall Hauch commented on KAFKA-5704: -- The fix is straightforward: [this block|http

[jira] [Created] (KAFKA-5706) log the name of the error instead of the error code in response objects

Jun Rao created KAFKA-5706: -- Summary: log the name of the error instead of the error code in response objects Key: KAFKA-5706 URL: https://issues.apache.org/jira/browse/KAFKA-5706 Project: Kafka Is

[jira] [Assigned] (KAFKA-5706) log the name of the error instead of the error code in response objects

[ https://issues.apache.org/jira/browse/KAFKA-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manasvi Gupta reassigned KAFKA-5706: Assignee: Manasvi Gupta > log the name of the error instead of the error code in response o

[jira] [Commented] (KAFKA-5706) log the name of the error instead of the error code in response objects

[ https://issues.apache.org/jira/browse/KAFKA-5706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16115273#comment-16115273 ] Manasvi Gupta commented on KAFKA-5706: -- Assigning to myself so I can work on this tic