[jira] [Commented] (KAFKA-7927) Read committed receives aborted events

[ https://issues.apache.org/jira/browse/KAFKA-7927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16769021#comment-16769021 ] huxihx commented on KAFKA-7927: --- [~gsomogyi] The console consumer you were using is the Scala consumer

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

[ https://issues.apache.org/jira/browse/KAFKA-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768990#comment-16768990 ] ASF GitHub Bot commented on KAFKA-7880: --- FrLy commented on pull request #6272:

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

[ https://issues.apache.org/jira/browse/KAFKA-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768984#comment-16768984 ] ASF GitHub Bot commented on KAFKA-7880: --- FrLy commented on pull request #6272:

[jira] [Commented] (KAFKA-7921) Instable KafkaStreamsTest

[ https://issues.apache.org/jira/browse/KAFKA-7921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768810#comment-16768810 ] Matthias J. Sax commented on KAFKA-7921: [~vvcephei] Test failed again. Can you have a look:

[jira] [Commented] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based

[ https://issues.apache.org/jira/browse/KAFKA-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768798#comment-16768798 ] Ryan commented on KAFKA-7864: - Hi [~yunfu], I'm still working on it, the code change has been approved, but

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768792#comment-16768792 ] Matthias J. Sax commented on KAFKA-6474: [~h314to] Just merge your latest PR. How many more do we

[jira] [Commented] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768790#comment-16768790 ] ASF GitHub Bot commented on KAFKA-6474: --- mjsax commented on pull request #5433: KAFKA-6474: Rewrite

[jira] [Commented] (KAFKA-7864) AdminZkClient.validateTopicCreate() should validate that partitions are 0-based

[ https://issues.apache.org/jira/browse/KAFKA-7864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768785#comment-16768785 ] YUN FU commented on KAFKA-7864: --- [~ctchen] Hi Ryan, just wondering whether you are still working on this

[jira] [Updated] (KAFKA-7711) Add a bounded flush() API to Kafka Producer

[ https://issues.apache.org/jira/browse/KAFKA-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ray Chiang updated KAFKA-7711: -- Component/s: producer > Add a bounded flush() API to Kafka Producer >

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7932: --- Fix Version/s: 2.3.0 > Streams needs to handle new Producer exceptions >

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7932: --- Priority: Critical (was: Major) > Streams needs to handle new Producer exceptions >

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7932: --- Affects Version/s: 2.2.0 > Streams needs to handle new Producer exceptions >

[jira] [Resolved] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

[ https://issues.apache.org/jira/browse/KAFKA-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7670. Resolution: Fixed > Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer >

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768628#comment-16768628 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:22 PM: - [~guozhang],

[jira] [Comment Edited] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768628#comment-16768628 ] Murad M edited comment on KAFKA-7930 at 2/14/19 7:20 PM: - [~guozhang],

[jira] [Created] (KAFKA-7932) Streams needs to handle new Producer exceptions

John Roesler created KAFKA-7932: --- Summary: Streams needs to handle new Producer exceptions Key: KAFKA-7932 URL: https://issues.apache.org/jira/browse/KAFKA-7932 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768628#comment-16768628 ] Murad M commented on KAFKA-7930: [~guozhang], definitely, that how it was done in the first place.

[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: --- Affects Version/s: (was: 2.1.0) > Invalid use of epoch cache with old message format

[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: --- Affects Version/s: (was: 1.1.1) 2.1.0 > Invalid use of epoch

[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: (was: 1.1.2) > Invalid use of epoch cache with old message format

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768604#comment-16768604 ] Guozhang Wang commented on KAFKA-7930: -- [~muradm] StreamsResetter allows the user to choose between

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768597#comment-16768597 ] Mateusz Owczarek commented on KAFKA-7882: - I understand that, I'm familiar with the wall-clock vs

[jira] [Commented] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

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

[jira] [Updated] (KAFKA-7916) Streams store cleanup: unify wrapping

[ https://issues.apache.org/jira/browse/KAFKA-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7916: --- Fix Version/s: 2.2.0 > Streams store cleanup: unify wrapping >

[jira] [Commented] (KAFKA-7811) Avoid unnecessary lock acquire when KafkaConsumer commits offsets

[ https://issues.apache.org/jira/browse/KAFKA-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768570#comment-16768570 ] ASF GitHub Bot commented on KAFKA-7811: --- guozhangwang commented on pull request #6119: KAFKA-7811:

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768565#comment-16768565 ] Matthias J. Sax commented on KAFKA-7882: Because wall-clock time eviction does not know anything

[jira] [Resolved] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7882. Resolution: Duplicate > StateStores are frequently closed during the 'transform' method >

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

[ https://issues.apache.org/jira/browse/KAFKA-7811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-7811: - Description: In KafkaConsumer#commitAsync that does not take offset parameters, we have the

[jira] [Resolved] (KAFKA-7916) Streams store cleanup: unify wrapping

[ https://issues.apache.org/jira/browse/KAFKA-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7916. - Resolution: Fixed > Streams store cleanup: unify wrapping >

[jira] [Closed] (KAFKA-7916) Streams store cleanup: unify wrapping

[ https://issues.apache.org/jira/browse/KAFKA-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-7916. --- > Streams store cleanup: unify wrapping > - > > Key:

[jira] [Commented] (KAFKA-7916) Streams store cleanup: unify wrapping

[ https://issues.apache.org/jira/browse/KAFKA-7916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768494#comment-16768494 ] ASF GitHub Bot commented on KAFKA-7916: --- guozhangwang commented on pull request #6255: KAFKA-7916:

[jira] [Updated] (KAFKA-5722) Refactor ConfigCommand to use the AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-5722: -- Fix Version/s: (was: 2.2.0) 2.3.0 > Refactor ConfigCommand to use the

[jira] [Updated] (KAFKA-5453) Controller may miss requests sent to the broker when zk session timeout happens.

[ https://issues.apache.org/jira/browse/KAFKA-5453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi updated KAFKA-5453: -- Fix Version/s: (was: 2.2.0) 2.3.0 > Controller may miss requests sent

[jira] [Commented] (KAFKA-7736) Consolidate Map usages in TransactionManager

[ https://issues.apache.org/jira/browse/KAFKA-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768363#comment-16768363 ] ASF GitHub Bot commented on KAFKA-7736: --- viktorsomogyi commented on pull request #6270: KAFKA-7736:

[jira] [Commented] (KAFKA-7925) Constant 100% cpu usage by all kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-7925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768321#comment-16768321 ] Abhi commented on KAFKA-7925: - I keep seeing below exception in all server logs. No clients are able to

[jira] [Commented] (KAFKA-7736) Consolidate Map usages in TransactionManager

[ https://issues.apache.org/jira/browse/KAFKA-7736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768285#comment-16768285 ] Viktor Somogyi commented on KAFKA-7736: --- [~hachikuji] Had a go on refactoring these map usages into

[jira] [Commented] (KAFKA-7882) StateStores are frequently closed during the 'transform' method

[ https://issues.apache.org/jira/browse/KAFKA-7882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16768064#comment-16768064 ] Mateusz Owczarek commented on KAFKA-7882: - Yes, we can, but there is still one unanswered

[jira] [Commented] (KAFKA-7930) StreamsResetter makes "changelog" topic naming assumptions

[ https://issues.apache.org/jira/browse/KAFKA-7930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767975#comment-16767975 ] Matthias J. Sax commented on KAFKA-7930: Fair enough. :) > StreamsResetter makes "changelog"

[jira] [Commented] (KAFKA-7928) Deprecate WindowStore.put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767952#comment-16767952 ] ASF GitHub Bot commented on KAFKA-7928: --- ouertani commented on pull request #6268: KAFKA-7928 URL: