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

[ https://issues.apache.org/jira/browse/KAFKA-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16361986#comment-16361986 ] Ismael Juma commented on KAFKA-6475: cc [~rsivaram] > ConfigException on the broker r

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

[ https://issues.apache.org/jira/browse/KAFKA-6446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16361999#comment-16361999 ] ASF GitHub Bot commented on KAFKA-6446: --- huxihx opened a new pull request #4563: KAF

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

[ 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-6106) Postpone normal processing of tasks within a thread until restoration of all tasks have completed

[ https://issues.apache.org/jira/browse/KAFKA-6106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362043#comment-16362043 ] ASF GitHub Bot commented on KAFKA-6106: --- kamalcph opened a new pull request #4564: K

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362098#comment-16362098 ] Ismael Juma commented on KAFKA-6549: [~junrao], any thoughts on how to fix the deadloc

[jira] [Commented] (KAFKA-6264) Log cleaner thread may die on legacy segment containing messages whose offsets are too large

[ https://issues.apache.org/jira/browse/KAFKA-6264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362105#comment-16362105 ] Ben Corlett commented on KAFKA-6264: In our production cluster we are running 0.10.2.1

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

[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362153#comment-16362153 ] Yaswanth Kumar commented on KAFKA-6536: --- I would like to start working on this issue

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

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 Project

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

[ 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 enabled

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

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 Iss

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

[ 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 se

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362269#comment-16362269 ] Antony Stubbs commented on KAFKA-6555: -- This requires a KIP right? > Making state st

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

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] [Updated] (KAFKA-6556) allow to attach callbacks in kafka streams, to be triggered when a window is expired

[ 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

[ 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] [Commented] (KAFKA-6238) Issues with protocol version when applying a rolling upgrade to 1.0.0

[ https://issues.apache.org/jira/browse/KAFKA-6238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362659#comment-16362659 ] Ivan Babrou commented on KAFKA-6238: We're upgrading from 0.11.0 and still see: {nofo

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

[ https://issues.apache.org/jira/browse/KAFKA-6536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362668#comment-16362668 ] Guozhang Wang commented on KAFKA-6536: -- Thanks Yaswanth, please follow the contributi

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

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362762#comment-16362762 ] Colin P. McCabe commented on KAFKA-2967: I would prefer asciidoc > Move Kafka doc

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

[ 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] [Created] (KAFKA-6559) Iterate record sets before calling Log.append

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: Improveme

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

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362870#comment-16362870 ] Matthias J. Sax commented on KAFKA-6555: Good question... [~guozhang] WDYT? > Mak

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362931#comment-16362931 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota closed pull request #4561: KAFKA-6

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362930#comment-16362930 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota opened a new pull request #4561: K

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362933#comment-16362933 ] ASF GitHub Bot commented on KAFKA-6503: --- rayokota opened a new pull request #4561: K

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

[ https://issues.apache.org/jira/browse/KAFKA-6511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362936#comment-16362936 ] ASF GitHub Bot commented on KAFKA-6511: --- hachikuji closed pull request #4516: KAFKA-

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

[ 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-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363022#comment-16363022 ] Guozhang Wang commented on KAFKA-6555: -- I would say yes; it changes the state protoco

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

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 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363139#comment-16363139 ] Robert Yokota commented on KAFKA-6503: -- With my setup where plugin.path was pointing

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

[ https://issues.apache.org/jira/browse/KAFKA-6503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Yokota reassigned KAFKA-6503: Assignee: Robert Yokota > Connect: Plugin scan is very slow > -

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

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] [Commented] (KAFKA-4608) RocksDBWindowStore.fetch() is inefficient for large ranges

[ https://issues.apache.org/jira/browse/KAFKA-4608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363350#comment-16363350 ] Guozhang Wang commented on KAFKA-4608: -- I have filed https://issues.apache.org/jira/b

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

[ 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

[ 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 when

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

[ 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