[jira] [Commented] (KAFKA-7601) Handle message format downgrades during upgrade of message format version

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

[jira] [Commented] (KAFKA-7791) Not log retriable exceptions as errors

[ https://issues.apache.org/jira/browse/KAFKA-7791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16816018#comment-16816018 ] Andrzej Ludwikowski commented on KAFKA-7791: Hello, any progress on this issu

[jira] [Created] (KAFKA-8225) handle conflicting static member id

Boyang Chen created KAFKA-8225: -- Summary: handle conflicting static member id Key: KAFKA-8225 URL: https://issues.apache.org/jira/browse/KAFKA-8225 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-8224) Add static member id into Subscription Info for better rebalance behavior

[ https://issues.apache.org/jira/browse/KAFKA-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8224: -- Assignee: Boyang Chen > Add static member id into Subscription Info for better rebalance behav

[jira] [Created] (KAFKA-8224) Add static member id into Subscription Info for better rebalance behavior

Boyang Chen created KAFKA-8224: -- Summary: Add static member id into Subscription Info for better rebalance behavior Key: KAFKA-8224 URL: https://issues.apache.org/jira/browse/KAFKA-8224 Project: Kafka

[jira] [Created] (KAFKA-8223) Deprecate group.initial.rebalance.delay

Boyang Chen created KAFKA-8223: -- Summary: Deprecate group.initial.rebalance.delay Key: KAFKA-8223 URL: https://issues.apache.org/jira/browse/KAFKA-8223 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-8222) Admin client changes to add ability to batch remove static members

[ https://issues.apache.org/jira/browse/KAFKA-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8222: --- Description: After leave group [changes|https://issues.apache.org/jira/browse/KAFKA-8221] become effe

[jira] [Created] (KAFKA-8222) Admin client changes to add ability to batch remove static members

Boyang Chen created KAFKA-8222: -- Summary: Admin client changes to add ability to batch remove static members Key: KAFKA-8222 URL: https://issues.apache.org/jira/browse/KAFKA-8222 Project: Kafka

[jira] [Created] (KAFKA-8221) Augment LeaveGroupRequest to batch operation

Boyang Chen created KAFKA-8221: -- Summary: Augment LeaveGroupRequest to batch operation Key: KAFKA-8221 URL: https://issues.apache.org/jira/browse/KAFKA-8221 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8220) Avoid kicking out members through rebalance timeout

Boyang Chen created KAFKA-8220: -- Summary: Avoid kicking out members through rebalance timeout Key: KAFKA-8220 URL: https://issues.apache.org/jira/browse/KAFKA-8220 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-8219) Add web documentation for static membership

Boyang Chen created KAFKA-8219: -- Summary: Add web documentation for static membership Key: KAFKA-8219 URL: https://issues.apache.org/jira/browse/KAFKA-8219 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815795#comment-16815795 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6565: KAF

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815772#comment-16815772 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #6564: K

[jira] [Commented] (KAFKA-8209) Wrong link for KStreams DSL in Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815770#comment-16815770 ] ASF GitHub Bot commented on KAFKA-8209: --- bbejeck commented on pull request #198: KA

[jira] [Commented] (KAFKA-8208) Broken link for out-of-order data in KStreams Core Concepts doc

[ https://issues.apache.org/jira/browse/KAFKA-8208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815749#comment-16815749 ] ASF GitHub Bot commented on KAFKA-8208: --- bbejeck commented on pull request #197: KA

[jira] [Resolved] (KAFKA-8214) Handling RecordTooLargeException in the main thread

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohan Parthasarathy resolved KAFKA-8214. Resolution: Duplicate > Handling RecordTooLargeException in the main thread > --

[jira] [Commented] (KAFKA-8214) Handling RecordTooLargeException in the main thread

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815607#comment-16815607 ] Matthias J. Sax commented on KAFKA-8214: No problem. Can you close this ticket? >

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815605#comment-16815605 ] Matthias J. Sax commented on KAFKA-8204: I would recommend to back port as far as

[jira] [Updated] (KAFKA-8134) ProducerConfig.LINGER_MS_CONFIG undocumented breaking change in kafka-clients 2.1

[ https://issues.apache.org/jira/browse/KAFKA-8134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-8134: --- Fix Version/s: 2.2.1 2.1.2 2.3.0 > ProducerConfig.LINGER_MS_CON

[jira] [Commented] (KAFKA-4336) Frequent log rolling when there's a mix of delayed and current data

[ https://issues.apache.org/jira/browse/KAFKA-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815567#comment-16815567 ] Chema Sanchez commented on KAFKA-4336: -- I would like to draw attention to this bug w

[jira] [Commented] (KAFKA-8214) Handling RecordTooLargeException in the main thread

[ https://issues.apache.org/jira/browse/KAFKA-8214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815551#comment-16815551 ] Mohan Parthasarathy commented on KAFKA-8214: Sorry Matthias. I was sort of get

[jira] [Commented] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815516#comment-16815516 ] John Roesler commented on KAFKA-8204: - How far back should we backport the fix for th

[jira] [Commented] (KAFKA-8153) Streaming application with state stores takes up to 1 hour to restart

[ https://issues.apache.org/jira/browse/KAFKA-8153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815507#comment-16815507 ] Matthias J. Sax commented on KAFKA-8153: {quote}cleanupconfig is some bean in Spr

[jira] [Commented] (KAFKA-8218) IllegalStateException while accessing context in Transformer

[ https://issues.apache.org/jira/browse/KAFKA-8218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815505#comment-16815505 ] Matthias J. Sax commented on KAFKA-8218: Check out the FAQ for this error:  [http

[jira] [Created] (KAFKA-8218) IllegalStateException while accessing context in Transformer

Bartłomiej Kępa created KAFKA-8218: -- Summary: IllegalStateException while accessing context in Transformer Key: KAFKA-8218 URL: https://issues.apache.org/jira/browse/KAFKA-8218 Project: Kafka

[jira] [Commented] (KAFKA-7685) Support loading trust stores from classpath

[ https://issues.apache.org/jira/browse/KAFKA-7685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815466#comment-16815466 ] Jorg Heymans commented on KAFKA-7685: - Alternatively, also consider accepting just an

[jira] [Resolved] (KAFKA-8182) IllegalStateException in NetworkClient.initiateConnect when handling UnknownHostException thrown from ClusterConnectionStates.connecting

[ https://issues.apache.org/jira/browse/KAFKA-8182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mark Anderson resolved KAFKA-8182. -- Resolution: Duplicate Resolving as I've confirmed this is a duplicate of KAFKA-7974 and is fixe

[jira] [Updated] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8204: Affects Version/s: 0.10.2.0 0.10.2.1 0.10.2.2

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815432#comment-16815432 ] John Roesler commented on KAFKA-7965: - Saw this again on  [https://builds.apache.org/

[jira] [Commented] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815421#comment-16815421 ] Braedon Vickers commented on KAFKA-4600: Great, sounds good. Thanks [~guozhang]

[jira] [Created] (KAFKA-8217) MockConsumer.poll executes pollTasks before checking wakeup flag

Kevin created KAFKA-8217: Summary: MockConsumer.poll executes pollTasks before checking wakeup flag Key: KAFKA-8217 URL: https://issues.apache.org/jira/browse/KAFKA-8217 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-8216) MockConsumer's poll(Duration timeout) method doesn't wait for timeout

Kevin created KAFKA-8216: Summary: MockConsumer's poll(Duration timeout) method doesn't wait for timeout Key: KAFKA-8216 URL: https://issues.apache.org/jira/browse/KAFKA-8216 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815252#comment-16815252 ] Matthias J. Sax commented on KAFKA-8201: Thanks [~andaag]! Will close this a "won

[jira] [Resolved] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8201. Resolution: Not A Bug > Kafka streams repartitioning topic settings crashing multiple nodes

[jira] [Comment Edited] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815156#comment-16815156 ] Anders Aagaard edited comment on KAFKA-8201 at 4/11/19 7:45 AM: ---

[jira] [Commented] (KAFKA-8201) Kafka streams repartitioning topic settings crashing multiple nodes

[ https://issues.apache.org/jira/browse/KAFKA-8201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815156#comment-16815156 ] Anders Aagaard commented on KAFKA-8201: --- Ah, that makes sense. Thanks for the extra

[jira] [Commented] (KAFKA-8200) TopologyTestDriver should offer an iterable signature of readOutput

[ https://issues.apache.org/jira/browse/KAFKA-8200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16815152#comment-16815152 ] Patrik Kleindl commented on KAFKA-8200: --- [~mjsax] I will do the write-up, please gi