[jira] [Resolved] (KAFKA-8230) Add static membership support in librd consumer client

[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8230. Resolution: Fixed Will be tracked on the librdKafka side, which seems to be done > Add static

[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=17065289#comment-17065289 ] ASF GitHub Bot commented on KAFKA-6145: --- ableegoldman commented on pull request #8337: KAFKA-6145:

[jira] [Created] (KAFKA-9752) Consumer rebalance can be stuck after new member timeout with old JoinGroup version

Jason Gustafson created KAFKA-9752: -- Summary: Consumer rebalance can be stuck after new member timeout with old JoinGroup version Key: KAFKA-9752 URL: https://issues.apache.org/jira/browse/KAFKA-9752

[jira] [Commented] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065258#comment-17065258 ] Akshit Khurana commented on KAFKA-8897: --- Hi there, new to the project but would love to contribute,

[jira] [Created] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

Boyang Chen created KAFKA-9751: -- Summary: Admin `FindCoordinator` call should go to controller instead of ZK Key: KAFKA-9751 URL: https://issues.apache.org/jira/browse/KAFKA-9751 Project: Kafka

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

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

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

[ https://issues.apache.org/jira/browse/KAFKA-7869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065234#comment-17065234 ] Dongjin Lee commented on KAFKA-7869: [~vvcephei] Sorry for the late reply. It would be better to

[jira] [Updated] (KAFKA-9749) TransactionMarkerRequestCompletionHandler should treat storage exceptions as retriable

[ https://issues.apache.org/jira/browse/KAFKA-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-9749: --- Affects Version/s: 2.5.0 > TransactionMarkerRequestCompletionHandler should treat storage exceptions

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

Bob Barrett created KAFKA-9750: -- Summary: Flaky test kafka.server.ReplicaManagerTest.testFencedErrorCausedByBecomeLeader Key: KAFKA-9750 URL: https://issues.apache.org/jira/browse/KAFKA-9750 Project:

[jira] [Updated] (KAFKA-9749) TransactionMarkerRequestCompletionHandler should treat storage exceptions as retriable

[ https://issues.apache.org/jira/browse/KAFKA-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett updated KAFKA-9749: --- Component/s: core > TransactionMarkerRequestCompletionHandler should treat storage exceptions as >

[jira] [Resolved] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Bellemare resolved KAFKA-9732. --- Resolution: Not A Problem Issue was with reporter's usage of the API. > Kafka Foreign-Key

[jira] [Commented] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065224#comment-17065224 ] Adam Bellemare commented on KAFKA-9732: --- [~vvcephei] Gah! Thank you! I was tearing my hair out

[jira] [Resolved] (KAFKA-9407) Return Immutable List from SchemaSourceTask

[ https://issues.apache.org/jira/browse/KAFKA-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-9407. --- Resolution: Fixed > Return Immutable List from SchemaSourceTask >

[jira] [Updated] (KAFKA-9407) Return Immutable List from SchemaSourceTask

[ https://issues.apache.org/jira/browse/KAFKA-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9407: -- Fix Version/s: 2.6.0 > Return Immutable List from SchemaSourceTask >

[jira] [Commented] (KAFKA-9407) Return Immutable List from SchemaSourceTask

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

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065190#comment-17065190 ] Guozhang Wang commented on KAFKA-8803: -- [~rocketraman] We found another cause that can let txn to be

[jira] [Resolved] (KAFKA-9742) StandbyTaskEOSIntegrationTest broken

[ https://issues.apache.org/jira/browse/KAFKA-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9742. - Resolution: Fixed > StandbyTaskEOSIntegrationTest broken >

[jira] [Commented] (KAFKA-9742) StandbyTaskEOSIntegrationTest broken

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

[jira] [Assigned] (KAFKA-9749) TransactionMarkerRequestCompletionHandler should treat storage exceptions as retriable

[ https://issues.apache.org/jira/browse/KAFKA-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Barrett reassigned KAFKA-9749: -- Assignee: Bob Barrett > TransactionMarkerRequestCompletionHandler should treat storage

[jira] [Created] (KAFKA-9749) TransactionMarkerRequestCompletionHandler should treat storage exceptions as retriable

Bob Barrett created KAFKA-9749: -- Summary: TransactionMarkerRequestCompletionHandler should treat storage exceptions as retriable Key: KAFKA-9749 URL: https://issues.apache.org/jira/browse/KAFKA-9749

[jira] [Updated] (KAFKA-9747) No tasks created for a connector

[ https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vit Koma updated KAFKA-9747: Attachment: connect.log > No tasks created for a connector > > >

[jira] [Commented] (KAFKA-9742) StandbyTaskEOSIntegrationTest broken

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

[jira] [Updated] (KAFKA-9747) No tasks created for a connector

[ https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vit Koma updated KAFKA-9747: Attachment: connect-distributed.properties Description: We are running Kafka Connect in a distributed

[jira] [Updated] (KAFKA-9466) Add documentation for new stream EOS change

[ https://issues.apache.org/jira/browse/KAFKA-9466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9466: --- Description: We shall fill in more details when we actually reach this stage. * new

[jira] [Assigned] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-3821: Assignee: Randall Hauch > Allow Kafka Connect source tasks to produce offset without

[jira] [Commented] (KAFKA-9453) Make transaction.id optional in group mode EOS

[ https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064999#comment-17064999 ] Matthias J. Sax commented on KAFKA-9453: [~bchen225242] Not sure if I understand this ticket. The

[jira] [Updated] (KAFKA-9719) Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade

[ https://issues.apache.org/jira/browse/KAFKA-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9719: --- Component/s: streams > Add Integration Test For ensuring the EOS-beta app would crash with

[jira] [Resolved] (KAFKA-9736) Use internal consumer config to fail for unsupported protocol

[ https://issues.apache.org/jira/browse/KAFKA-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9736. Resolution: Duplicate > Use internal consumer config to fail for unsupported protocol >

[jira] [Assigned] (KAFKA-9719) Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade

[ https://issues.apache.org/jira/browse/KAFKA-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9719: -- Assignee: Matthias J. Sax > Add Integration Test For ensuring the EOS-beta app would

[jira] [Commented] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064992#comment-17064992 ] John Roesler commented on KAFKA-9732: - Oh, also FYI, you'll be interested in

[jira] [Commented] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064989#comment-17064989 ] John Roesler commented on KAFKA-9732: - Hey [~abellemare] , I think the mapValues is where you're

[jira] [Assigned] (KAFKA-9748) Extend EOS integration test for EOS-beta

[ https://issues.apache.org/jira/browse/KAFKA-9748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9748: -- Assignee: Matthias J. Sax > Extend EOS integration test for EOS-beta >

[jira] [Created] (KAFKA-9748) Extend EOS integration test for EOS-beta

Matthias J. Sax created KAFKA-9748: -- Summary: Extend EOS integration test for EOS-beta Key: KAFKA-9748 URL: https://issues.apache.org/jira/browse/KAFKA-9748 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9651) Divide by zero in DefaultPartitioner

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

[jira] [Comment Edited] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064893#comment-17064893 ] Sean Glover edited comment on KAFKA-7548 at 3/23/20, 3:52 PM: -- Hi

[jira] [Commented] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064893#comment-17064893 ] Sean Glover commented on KAFKA-7548: Hi [~hryhoriev.nick].  That behaviour was not changed. 

[jira] [Created] (KAFKA-9747) No tasks created for a connector

Vit Koma created KAFKA-9747: --- Summary: No tasks created for a connector Key: KAFKA-9747 URL: https://issues.apache.org/jira/browse/KAFKA-9747 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-7548) KafkaConsumer should not throw away already fetched data for paused partitions.

[ https://issues.apache.org/jira/browse/KAFKA-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064875#comment-17064875 ] Nick Hryhoriev commented on KAFKA-7548: --- Hi [~seglo],  I got through PR, but don't understand how

[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=17064856#comment-17064856 ] ASF GitHub Bot commented on KAFKA-6145: --- cadonna commented on pull request #8334: KAFKA-6145: Add

[jira] [Created] (KAFKA-9746) MM2 produces messages in the wrong cluster

Marcel Renders created KAFKA-9746: - Summary: MM2 produces messages in the wrong cluster Key: KAFKA-9746 URL: https://issues.apache.org/jira/browse/KAFKA-9746 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-9745) Attribute is missed in kafka mirror maker metrics

Nikita Krasnov created KAFKA-9745: - Summary: Attribute is missed in kafka mirror maker metrics Key: KAFKA-9745 URL: https://issues.apache.org/jira/browse/KAFKA-9745 Project: Kafka Issue

[jira] [Created] (KAFKA-9744) SchemaProjector fails to handle backwards-compatible schema change

Jurgis Pods created KAFKA-9744: -- Summary: SchemaProjector fails to handle backwards-compatible schema change Key: KAFKA-9744 URL: https://issues.apache.org/jira/browse/KAFKA-9744 Project: Kafka

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064643#comment-17064643 ] Stefan Meiforth Gulbrandsen commented on KAFKA-1194: Any new status on this? > The

[jira] [Commented] (KAFKA-9688) kafka-topic.sh should show KIP-455 adding and removing replicas

[ https://issues.apache.org/jira/browse/KAFKA-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064578#comment-17064578 ] ASF GitHub Bot commented on KAFKA-9688: --- d8tltanc commented on pull request #8332: KAFKA-9688: