[jira] [Commented] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

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

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Description: Test {{org.apache.kafka.streams.integration.EosIntegrationTest >

[jira] [Commented] (KAFKA-9750) Flaky test kafka.server.ReplicaManagerTest.testFencedErrorCausedByBecomeLeader

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

[jira] [Comment Edited] (KAFKA-9800) [KIP-580] Admin Client Exponential Backoff Implementation

[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074241#comment-17074241 ] Cheng Tan edited comment on KAFKA-9800 at 4/3/20, 3:16 AM: --- Some thoughts:  

[jira] [Commented] (KAFKA-9800) [KIP-580] Admin Client Exponential Backoff Implementation

[ https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074241#comment-17074241 ] Cheng Tan commented on KAFKA-9800: -- Some thoughts:   *Call*       retry(failedCallRetryContext){

[jira] [Commented] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074231#comment-17074231 ] ASF GitHub Bot commented on KAFKA-9812: --- vvcephei commented on pull request #8411: KAFKA-9812: fix

[jira] [Commented] (KAFKA-9809) Shrink transaction timeout for Streams

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

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9803: - Component/s: streams consumer > Allow producers to recover gracefully from

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-9803: - Component/s: (was: consumer) producer > Allow producers to recover

[jira] [Assigned] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9812: --- Assignee: John Roesler (was: Boyang Chen) > Integration tests hang and timeout the entire

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074192#comment-17074192 ] ASF GitHub Bot commented on KAFKA-6145: --- ableegoldman commented on pull request #8409: KAFKA-6145:

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Labels: flaky flaky-build (was: flaky-build) > Integration tests hang and

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Labels: flaky-build (was: ) > Integration tests hang and timeout the entire

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Component/s: streams > Integration tests hang and timeout the entire PR build

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Description: Test {{org.apache.kafka.streams.integration.EosIntegrationTest >

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Description: Test {{org.apache.kafka.streams.integration.EosIntegrationTest >

[jira] [Updated] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9812: -- Description: Test {{org.apache.kafka.streams.integration.EosIntegrationTest >

[jira] [Created] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

Konstantine Karantasis created KAFKA-9812: - Summary: Integration tests hang and timeout the entire PR build on jenkins Key: KAFKA-9812 URL: https://issues.apache.org/jira/browse/KAFKA-9812

[jira] [Commented] (KAFKA-9778) Add validateConnector functionality to the EmbeddedConnectCluster

[ https://issues.apache.org/jira/browse/KAFKA-9778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074153#comment-17074153 ] ASF GitHub Bot commented on KAFKA-9778: --- kkonstantine commented on pull request #8359: KAFKA-9778:

[jira] [Created] (KAFKA-9811) TransactionMetadata state and pendingState are non-volatile and read outside the metadata lock

Bob Barrett created KAFKA-9811: -- Summary: TransactionMetadata state and pendingState are non-volatile and read outside the metadata lock Key: KAFKA-9811 URL: https://issues.apache.org/jira/browse/KAFKA-9811

[jira] [Commented] (KAFKA-9482) mirror maker 2.0 doesn't replicates (create topic) created automatically by producing messages

[ https://issues.apache.org/jira/browse/KAFKA-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074132#comment-17074132 ] Rens Groothuijsen commented on KAFKA-9482: -- [~grinfeld] It works for me. The default source

[jira] [Commented] (KAFKA-6529) Broker leaks memory and file descriptors after sudden client disconnects

[ https://issues.apache.org/jira/browse/KAFKA-6529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074102#comment-17074102 ] Graham Campbell commented on KAFKA-6529: [~zzccctv] I originally reproduced it in a test

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073978#comment-17073978 ] ASF GitHub Bot commented on KAFKA-6145: --- vvcephei commented on pull request #8337: KAFKA-6145: Pt.

[jira] [Commented] (KAFKA-9810) Document Connect Root REST API on /

[ https://issues.apache.org/jira/browse/KAFKA-9810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073972#comment-17073972 ] ASF GitHub Bot commented on KAFKA-9810: --- kkonstantine commented on pull request #8408: KAFKA-9810:

[jira] [Created] (KAFKA-9810) Document Connect Root REST API on /

Konstantine Karantasis created KAFKA-9810: - Summary: Document Connect Root REST API on / Key: KAFKA-9810 URL: https://issues.apache.org/jira/browse/KAFKA-9810 Project: Kafka Issue

[jira] [Commented] (KAFKA-9809) Shrink transaction timeout for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073955#comment-17073955 ] ASF GitHub Bot commented on KAFKA-9809: --- abbccdda commented on pull request #8407: KAFKA-9809:

[jira] [Assigned] (KAFKA-9809) Shrink transaction timeout for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9809: -- Assignee: Boyang Chen > Shrink transaction timeout for Streams >

[jira] [Created] (KAFKA-9809) Shrink transaction timeout for Streams

Boyang Chen created KAFKA-9809: -- Summary: Shrink transaction timeout for Streams Key: KAFKA-9809 URL: https://issues.apache.org/jira/browse/KAFKA-9809 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-9808) Refactor State Store Hierarchy

Richard Yu created KAFKA-9808: - Summary: Refactor State Store Hierarchy Key: KAFKA-9808 URL: https://issues.apache.org/jira/browse/KAFKA-9808 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073887#comment-17073887 ] Matthias J. Sax commented on KAFKA-9803: In fact, we catch `ProducerFencedException` for this

[jira] [Updated] (KAFKA-9807) Race condition updating high watermark allows reads above LSO

[ https://issues.apache.org/jira/browse/KAFKA-9807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9807: --- Affects Version/s: 0.11.0.3 1.0.2 1.1.1

[jira] [Created] (KAFKA-9807) Race condition updating high watermark allows reads above LSO

Jason Gustafson created KAFKA-9807: -- Summary: Race condition updating high watermark allows reads above LSO Key: KAFKA-9807 URL: https://issues.apache.org/jira/browse/KAFKA-9807 Project: Kafka

[jira] [Created] (KAFKA-9806) Unable to consume when __consumer_offsets is created under insufficient cluster ACLs

Paolo Moriello created KAFKA-9806: - Summary: Unable to consume when __consumer_offsets is created under insufficient cluster ACLs Key: KAFKA-9806 URL: https://issues.apache.org/jira/browse/KAFKA-9806

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073581#comment-17073581 ] Evan Williams commented on KAFKA-4084: -- [~sql_consulting] Thanks! No stress at all. :) > automated

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073468#comment-17073468 ] Bruno Cadonna commented on KAFKA-9770: -- I will keep this ticket open until you will have tried to

[jira] [Created] (KAFKA-9805) Running MirrorMaker in a Connect cluster,but the task not running

ZHAO GH created KAFKA-9805: -- Summary: Running MirrorMaker in a Connect cluster,but the task not running Key: KAFKA-9805 URL: https://issues.apache.org/jira/browse/KAFKA-9805 Project: Kafka Issue

[jira] [Created] (KAFKA-9804) Extract ConsumerPerform config into one file

jiamei xie created KAFKA-9804: - Summary: Extract ConsumerPerform config into one file Key: KAFKA-9804 URL: https://issues.apache.org/jira/browse/KAFKA-9804 Project: Kafka Issue Type: Bug