[jira] [Updated] (KAFKA-6557) Kafka Consumer Offsets are unavailable during rebalancing

2018-02-13 Thread Wouter Bancken (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wouter Bancken updated KAFKA-6557: -- Description: Using the kafka-consumer-groups tool to fetch the consumer offsets, the offsets

[jira] [Created] (KAFKA-6557) Kafka Consumer Offsets are unavailable during rebalancing

2018-02-13 Thread Wouter Bancken (JIRA)
Wouter Bancken created KAFKA-6557: - Summary: Kafka Consumer Offsets are unavailable during rebalancing Key: KAFKA-6557 URL: https://issues.apache.org/jira/browse/KAFKA-6557 Project: Kafka

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-02-13 Thread Antony Stubbs (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362269#comment-16362269 ] Antony Stubbs commented on KAFKA-6555: -- This requires a KIP right? > Making state store queryable

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-13 Thread Yaswanth Kumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362153#comment-16362153 ] Yaswanth Kumar commented on KAFKA-6536: --- I would like to start working on this issue. > Streams

[jira] [Created] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

2018-02-13 Thread igor mazor (JIRA)
igor mazor created KAFKA-6556: - Summary: allow to attach callbacks in kafka streams, to be triggered when a window is expired Key: KAFKA-6556 URL: https://issues.apache.org/jira/browse/KAFKA-6556

[jira] [Assigned] (KAFKA-6512) Java Producer: Excessive memory usage with compression enabled

2018-02-13 Thread Rajini Sivaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-6512: - Assignee: Rajini Sivaram > Java Producer: Excessive memory usage with compression

[jira] [Commented] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client

2018-02-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361986#comment-16361986 ] Ismael Juma commented on KAFKA-6475: cc [~rsivaram] > ConfigException on the broker results in

[jira] [Commented] (KAFKA-6549) Deadlock while processing Controller Events

2018-02-13 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362098#comment-16362098 ] Ismael Juma commented on KAFKA-6549: [~junrao], any thoughts on how to fix the deadlock? > Deadlock

[jira] [Commented] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16361999#comment-16361999 ] ASF GitHub Bot commented on KAFKA-6446: --- huxihx opened a new pull request #4563: KAFKA-6446:

[jira] [Commented] (KAFKA-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362043#comment-16362043 ] ASF GitHub Bot commented on KAFKA-6106: --- kamalcph opened a new pull request #4564: KAFKA-6106;

[jira] [Assigned] (KAFKA-6446) KafkaProducer with transactionId endless waits when bootstrap server is down

2018-02-13 Thread huxihx (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-6446: - Assignee: huxihx > KafkaProducer with transactionId endless waits when bootstrap server is down >

[jira] [Commented] (KAFKA-6099) Seeking consumer to evicted offset resets the offset

2018-02-13 Thread JIRA
[ https://issues.apache.org/jira/browse/KAFKA-6099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362072#comment-16362072 ] Tomáš Králík commented on KAFKA-6099: - Hey, This is bit old - but for whoever finds this - there is a

[jira] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

2018-02-13 Thread igor mazor (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] igor mazor updated KAFKA-6556: -- Description: Allowing to attach callbacks in kafka streams, to be triggered when a window is expired,

[jira] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

2018-02-13 Thread igor mazor (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] igor mazor updated KAFKA-6556: -- Description: Allowing to attach callbacks in kafka streams, to be triggered when a window is expired,

[jira] [Created] (KAFKA-6558) Pre-load topics metadata in Mirror maker

2018-02-13 Thread Michal Turek (JIRA)
Michal Turek created KAFKA-6558: --- Summary: Pre-load topics metadata in Mirror maker Key: KAFKA-6558 URL: https://issues.apache.org/jira/browse/KAFKA-6558 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-2967) Move Kafka documentation to ReStructuredText

2018-02-13 Thread Colin P. McCabe (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362762#comment-16362762 ] Colin P. McCabe commented on KAFKA-2967: I would prefer asciidoc > Move Kafka documentation to

[jira] [Commented] (KAFKA-6536) Streams quickstart pom.xml is missing versions for a bunch of plugins

2018-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362668#comment-16362668 ] Guozhang Wang commented on KAFKA-6536: -- Thanks Yaswanth, please follow the contribution guidance to

[jira] [Resolved] (KAFKA-6472) WordCount example code error

2018-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6472. Resolution: Fixed > WordCount example code error > > >

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-02-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363022#comment-16363022 ] Guozhang Wang commented on KAFKA-6555: -- I would say yes; it changes the state protocol of a Streams

[jira] [Created] (KAFKA-6559) Iterate record sets before calling Log.append

2018-02-13 Thread Todd Palino (JIRA)
Todd Palino created KAFKA-6559: -- Summary: Iterate record sets before calling Log.append Key: KAFKA-6559 URL: https://issues.apache.org/jira/browse/KAFKA-6559 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362931#comment-16362931 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota closed pull request #4561: KAFKA-6503: Parallelize

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362930#comment-16362930 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota opened a new pull request #4561: KAFKA-6503:

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

2018-02-13 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362870#comment-16362870 ] Matthias J. Sax commented on KAFKA-6555: Good question... [~guozhang] WDYT? > Making state store

[jira] [Commented] (KAFKA-6559) Iterate record sets before calling Log.append

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362898#comment-16362898 ] ASF GitHub Bot commented on KAFKA-6559: --- toddpalino opened a new pull request #4567: KAFKA-6559:

[jira] [Resolved] (KAFKA-6511) Connect header parser incorrectly parses arrays

2018-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6511. Resolution: Fixed > Connect header parser incorrectly parses arrays >

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362933#comment-16362933 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota opened a new pull request #4561: KAFKA-6503:

[jira] [Commented] (KAFKA-6511) Connect header parser incorrectly parses arrays

2018-02-13 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362936#comment-16362936 ] ASF GitHub Bot commented on KAFKA-6511: --- hachikuji closed pull request #4516: KAFKA-6511: Corrected

[jira] [Created] (KAFKA-6560) Use single-point queries than range queries for windowed aggregation operators

2018-02-13 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-6560: Summary: Use single-point queries than range queries for windowed aggregation operators Key: KAFKA-6560 URL: https://issues.apache.org/jira/browse/KAFKA-6560

[jira] [Commented] (KAFKA-6503) Connect: Plugin scan is very slow

2018-02-13 Thread Robert Yokota (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363139#comment-16363139 ] Robert Yokota commented on KAFKA-6503: -- With my setup where plugin.path was pointing to share/java,

[jira] [Created] (KAFKA-6561) Change visibility of aclMatch in SimpleAclAuthorizer to protected to allow overriding in subclasses

2018-02-13 Thread JIRA
Sönke Liebau created KAFKA-6561: --- Summary: Change visibility of aclMatch in SimpleAclAuthorizer to protected to allow overriding in subclasses Key: KAFKA-6561 URL: https://issues.apache.org/jira/browse/KAFKA-6561

[jira] [Reopened] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

2018-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-4221: > KafkaConsumer Fetcher can send ListOffsets requests in parallel when > initializing position

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

2018-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Fixed > KafkaConsumer Fetcher can send ListOffsets requests in parallel when >

[jira] [Resolved] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

2018-02-13 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4221. Resolution: Duplicate > KafkaConsumer Fetcher can send ListOffsets requests in parallel