[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

2019-01-10 Thread Ashish Surana (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740052#comment-16740052 ] Ashish Surana commented on KAFKA-7149: -- Is this change on track for 2.2.0 release. I believe this is

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2019-01-10 Thread flying (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740039#comment-16740039 ] flying commented on KAFKA-3980: --- Version:2.1.0, has the same issue. !issue.jpg! > JmxReporter uses

[jira] [Updated] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

2019-01-10 Thread flying (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] flying updated KAFKA-3980: -- Attachment: issue.jpg > JmxReporter uses excessive memory causing OutOfMemoryException >

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739909#comment-16739909 ] ASF GitHub Bot commented on KAFKA-7040: --- apovzner commented on pull request #6122: KAFKA-7040:

[jira] [Reopened] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-7741: - > Bad dependency via SBT > -- > > Key: KAFKA-7741 >

[jira] [Commented] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739897#comment-16739897 ] John Roesler commented on KAFKA-7741: - The fix is merged, so I'll update the fix versions. I still

[jira] [Resolved] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-7741. -- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 2.2.0

[jira] [Commented] (KAFKA-7749) confluent does not provide option to set consumer properties at connector level

2019-01-10 Thread Paul Davidson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739888#comment-16739888 ] Paul Davidson commented on KAFKA-7749: -- Hi [~sliebau]. You can probably ignore the comment about

[jira] [Commented] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739876#comment-16739876 ] ASF GitHub Bot commented on KAFKA-7741: --- guozhangwang commented on pull request #6121: KAFKA-7741:

[jira] [Commented] (KAFKA-4453) add request prioritization

2019-01-10 Thread Mayuresh Gharat (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739822#comment-16739822 ] Mayuresh Gharat commented on KAFKA-4453: Hi [~sriharsha], Yes, the PR is already up. I got +1

[jira] [Commented] (KAFKA-4453) add request prioritization

2019-01-10 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739798#comment-16739798 ] Sriharsha Chintalapani commented on KAFKA-4453: --- Hi [~mgharat] checking to see if you are

[jira] [Commented] (KAFKA-7741) Bad dependency via SBT

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739745#comment-16739745 ] ASF GitHub Bot commented on KAFKA-7741: --- vvcephei commented on pull request #6121: KAFKA-7741:

[jira] [Comment Edited] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739701#comment-16739701 ] John Roesler edited comment on KAFKA-7806 at 1/10/19 7:16 PM: -- Thanks

[jira] [Comment Edited] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739701#comment-16739701 ] John Roesler edited comment on KAFKA-7806 at 1/10/19 7:16 PM: -- Thanks

[jira] [Commented] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739701#comment-16739701 ] John Roesler commented on KAFKA-7806: - Thanks [~bchen225242], I hadn't looked at KIP-393 yet, but I

[jira] [Updated] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration

2019-01-10 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7790: --- Description: If an Agent process is restarted, it will be re-sent the worker specifications

[jira] [Updated] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration

2019-01-10 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7790: --- Description: If an Agent process is restarted, it will be re-sent the worker specifications

[jira] [Updated] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration

2019-01-10 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7790: --- Description: If an Agent process is restarted, it will be re-sent the worker specifications

[jira] [Updated] (KAFKA-7790) Fix Bugs in Trogdor Task Expiration

2019-01-10 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-7790: --- Summary: Fix Bugs in Trogdor Task Expiration (was: Trogdor - Does not time out tasks in

[jira] [Comment Edited] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739601#comment-16739601 ] John Roesler edited comment on KAFKA-7748 at 1/10/19 4:50 PM: -- This has been

[jira] [Updated] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7748: Labels: needs-kip (was: ) > Add wall clock TimeDefinition for suppression of intermediate events

[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

2019-01-10 Thread John Roesler (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739601#comment-16739601 ] John Roesler commented on KAFKA-7748: - This has been a big stumbling block for users of Suppress. It

[jira] [Commented] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster

2019-01-10 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739567#comment-16739567 ] Christoffer Hammarström commented on KAFKA-7802: Sounds like you might be affected by

[jira] [Comment Edited] (KAFKA-7802) Connection to Broker Disconnected Taking Down the Whole Cluster

2019-01-10 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-7802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739567#comment-16739567 ] Christoffer Hammarström edited comment on KAFKA-7802 at 1/10/19 4:15 PM:

[jira] [Updated] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commit offsets

2019-01-10 Thread lambdaliu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lambdaliu updated KAFKA-7811: - Description: In KafkaConsumer#commitSync, we have the following logic: {code:java} public void

[jira] [Assigned] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

2019-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-5994: Assignee: Manikumar > Improve transparency of broker user ACL misconfigurations >

[jira] [Commented] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739407#comment-16739407 ] ASF GitHub Bot commented on KAFKA-5994: --- omkreddy commented on pull request #5021: KAFKA-5994: Log

[jira] [Resolved] (KAFKA-5994) Improve transparency of broker user ACL misconfigurations

2019-01-10 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5994. -- Resolution: Fixed Fix Version/s: 2.2.0 Issue resolved by pull request 5021

[jira] [Created] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commit offsets

2019-01-10 Thread lambdaliu (JIRA)
lambdaliu created KAFKA-7811: Summary: Avoid unnecessary lock acquire when KafkaConsumer commit offsets Key: KAFKA-7811 URL: https://issues.apache.org/jira/browse/KAFKA-7811 Project: Kafka

[jira] [Commented] (KAFKA-7804) Update the docs for KIP-377

2019-01-10 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739349#comment-16739349 ] ASF GitHub Bot commented on KAFKA-7804: --- viktorsomogyi commented on pull request #6118: KAFKA-7804:

[jira] [Updated] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases

2019-01-10 Thread Daniele Ascione (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniele Ascione updated KAFKA-7794: --- Description: For some input for the timestamps (different from -1 or -2) the GetOffset is

[jira] [Commented] (KAFKA-7810) AdminClient not found flink consumer group

2019-01-10 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739280#comment-16739280 ] huxihx commented on KAFKA-7810: --- Seems you are using kafka.admin.AdminClient which is already marked as

[jira] [Created] (KAFKA-7810) AdminClient not found flink consumer group

2019-01-10 Thread dengjie (JIRA)
dengjie created KAFKA-7810: -- Summary: AdminClient not found flink consumer group Key: KAFKA-7810 URL: https://issues.apache.org/jira/browse/KAFKA-7810 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7809) Getting uncaught exception in kafka-producer-network-thread | producer-7686: java.lang.OutOfMemoryError: Java heap space

2019-01-10 Thread Suman Kalyan Ghosh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739218#comment-16739218 ] Suman Kalyan Ghosh commented on KAFKA-7809: --- Can someone help on this ? This is a blocker for

[jira] [Commented] (KAFKA-6767) OffsetCheckpoint write assumes parent directory exists

2019-01-10 Thread Patrik Kleindl (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16739197#comment-16739197 ] Patrik Kleindl commented on KAFKA-6767: --- [~guozhang] Thanks, a restart of the whole application