[jira] [Updated] (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 ] Anders Aagaard updated KAFKA-8201: -- Affects Version/s: 2.0.0 > Kafka streams repartitioning topic settings crashing multiple nodes

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

Anders Aagaard created KAFKA-8201: - Summary: Kafka streams repartitioning topic settings crashing multiple nodes Key: KAFKA-8201 URL: https://issues.apache.org/jira/browse/KAFKA-8201 Project: Kafka

[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=16813069#comment-16813069 ] Anders Aagaard commented on KAFKA-8201: --- Another question here : Why use infinite r

[jira] [Updated] (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 ] Anders Aagaard updated KAFKA-8201: -- Description: We had an incident in a setup using kafka streams version 2.0.0 and kafka version

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813140#comment-16813140 ] Jonathan Santilli commented on KAFKA-7656: -- Hello [~jagsancio], this is the only

[jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813140#comment-16813140 ] Jonathan Santilli edited comment on KAFKA-7656 at 4/9/19 8:53 AM: -

[jira] [Created] (KAFKA-8202) StackOverflowError on producer when splitting batches

Daniel Krawczyk created KAFKA-8202: -- Summary: StackOverflowError on producer when splitting batches Key: KAFKA-8202 URL: https://issues.apache.org/jira/browse/KAFKA-8202 Project: Kafka Issue

[jira] [Updated] (KAFKA-8202) StackOverflowError on producer when splitting batches

[ https://issues.apache.org/jira/browse/KAFKA-8202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniel Krawczyk updated KAFKA-8202: --- Description: Hello, recently we came across a StackOverflowError error in the Kafka producer

[jira] [Commented] (KAFKA-6755) MaskField SMT should optionally take a literal value to use instead of using null

[ https://issues.apache.org/jira/browse/KAFKA-6755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813197#comment-16813197 ] Valeria Vasylieva commented on KAFKA-6755: -- [~rhauch] discussion did not gain lo

[jira] [Commented] (KAFKA-6675) Connect workers should log plugin path and available plugins more clearly

[ https://issues.apache.org/jira/browse/KAFKA-6675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813204#comment-16813204 ] Valeria Vasylieva commented on KAFKA-6675: -- [~rhauch] thank you for clarificatio

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813228#comment-16813228 ] Jonathan Santilli commented on KAFKA-7656: -- Enabling the TRACE level shows a lot

[jira] [Created] (KAFKA-8203) plaintext connections to SSL secured broker can be handled more elegantly

Jorg Heymans created KAFKA-8203: --- Summary: plaintext connections to SSL secured broker can be handled more elegantly Key: KAFKA-8203 URL: https://issues.apache.org/jira/browse/KAFKA-8203 Project: Kafka

[jira] [Updated] (KAFKA-8194) MessagesInPerSec incorrect value when when transactional messaging are enabled

[ https://issues.apache.org/jira/browse/KAFKA-8194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Odyldzhon Toshbekov updated KAFKA-8194: --- Summary: MessagesInPerSec incorrect value when when transactional messaging are enabl

[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=16813425#comment-16813425 ] Bill Bejeck commented on KAFKA-7965: Saw this failure again  [https://builds.apache.o

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813550#comment-16813550 ] Dmitry Minkovsky commented on KAFKA-5998: - [~guozhang] I am using kafka_2.12-2.1.

[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=16813573#comment-16813573 ] Bill Bejeck commented on KAFKA-8201: Hi Anders Aagaard, I'm not sure this is a bug f

[jira] [Assigned] (KAFKA-8203) plaintext connections to SSL secured broker can be handled more elegantly

[ https://issues.apache.org/jira/browse/KAFKA-8203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-8203: - Assignee: Satish Duggana > plaintext connections to SSL secured broker c

[jira] [Commented] (KAFKA-5061) client.id should be set for Connect producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-5061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813603#comment-16813603 ] Paul Davidson commented on KAFKA-5061: -- Voting is now underway on [KIP-411|https://

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

John Roesler created KAFKA-8204: --- Summary: Streams may flush state stores in the incorrect order Key: KAFKA-8204 URL: https://issues.apache.org/jira/browse/KAFKA-8204 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813626#comment-16813626 ] John Roesler commented on KAFKA-7895: - I'm tracking the incorrect flushing behavior i

[jira] [Comment Edited] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813626#comment-16813626 ] John Roesler edited comment on KAFKA-7895 at 4/9/19 5:08 PM: -

[jira] [Created] (KAFKA-8205) Kafka SSL encryption of dataat rest

Niten Aggarwal created KAFKA-8205: - Summary: Kafka SSL encryption of dataat rest Key: KAFKA-8205 URL: https://issues.apache.org/jira/browse/KAFKA-8205 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8205) Kafka SSL encryption of data at rest

[ https://issues.apache.org/jira/browse/KAFKA-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Niten Aggarwal updated KAFKA-8205: -- Summary: Kafka SSL encryption of data at rest (was: Kafka SSL encryption of dataat rest) > Ka

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[jira] [Commented] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813657#comment-16813657 ] Jonathan Santilli commented on KAFKA-7656: -- Currently 2.2, we have updated from

[jira] [Commented] (KAFKA-8205) Kafka SSL encryption of data at rest

[ https://issues.apache.org/jira/browse/KAFKA-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813659#comment-16813659 ] Sriharsha Chintalapani commented on KAFKA-8205: --- [~nitena2019] This is ques

[jira] [Comment Edited] (KAFKA-7656) ReplicaManager fetch fails on leader due to long/integer overflow

[ https://issues.apache.org/jira/browse/KAFKA-7656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813657#comment-16813657 ] Jonathan Santilli edited comment on KAFKA-7656 at 4/9/19 5:38 PM: -

[jira] [Commented] (KAFKA-8205) Kafka SSL encryption of data at rest

[ https://issues.apache.org/jira/browse/KAFKA-8205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813672#comment-16813672 ] Niten Aggarwal commented on KAFKA-8205: --- Hi [~sriharsha], Sure next time i will su

[jira] [Created] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

alex gabriel created KAFKA-8206: --- Summary: A consumer can't discover new group coordinator when the cluster was partly restarted Key: KAFKA-8206 URL: https://issues.apache.org/jira/browse/KAFKA-8206 Pro

[jira] [Updated] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] alex gabriel updated KAFKA-8206: Description: *A consumer can't discover new group coordinator when the cluster was partly restarte

[jira] [Updated] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] alex gabriel updated KAFKA-8206: Description: *A consumer can't discover new group coordinator when the cluster was partly restarte

[jira] [Updated] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] alex gabriel updated KAFKA-8206: Description: *A consumer can't discover new group coordinator when the cluster was partly restarte

[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=16813748#comment-16813748 ] ASF GitHub Bot commented on KAFKA-8204: --- vvcephei commented on pull request #6555:

[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=16813847#comment-16813847 ] ASF GitHub Bot commented on KAFKA-8200: --- pkleindl commented on pull request #6556:

[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=16813848#comment-16813848 ] Patrik Kleindl commented on KAFKA-8200: --- [~mjsax] Does this require a KIP? I took t

[jira] [Updated] (KAFKA-7897) Invalid use of epoch cache with old message format versions

[ https://issues.apache.org/jira/browse/KAFKA-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7897: --- Fix Version/s: 1.1.2 > Invalid use of epoch cache with old message format versions >

[jira] [Commented] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813937#comment-16813937 ] Gene Yi commented on KAFKA-7093: seems empty file leader-epoch-checkpoint for each topic

[jira] [Commented] (KAFKA-7093) Kafka warn messages after upgrade from 0.11.0.1 to 1.1.0

[ https://issues.apache.org/jira/browse/KAFKA-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813971#comment-16813971 ] Gene Yi commented on KAFKA-7093: it's indeed the bug mentioned by [~gwenshap],  https://i

[jira] [Commented] (KAFKA-7362) enable kafka broker to remove orphan partitions automatically

[ https://issues.apache.org/jira/browse/KAFKA-7362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813990#comment-16813990 ] Dhruvil Shah commented on KAFKA-7362: - [~xiongqiwu] from my understanding, we could o

[jira] [Comment Edited] (KAFKA-7362) enable kafka broker to remove orphan partitions automatically

[ https://issues.apache.org/jira/browse/KAFKA-7362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16813990#comment-16813990 ] Dhruvil Shah edited comment on KAFKA-7362 at 4/10/19 2:12 AM: -

[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=16814015#comment-16814015 ] ASF GitHub Bot commented on KAFKA-7965: --- huxihx commented on pull request #6557: KA

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

[ https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16814078#comment-16814078 ] Di Shang commented on KAFKA-4453: - Hi The new metric introduced here breaks our metric p