[jira] [Created] (KAFKA-9042) Auto infer external topic partitions in stream reset tool

Boyang Chen created KAFKA-9042: -- Summary: Auto infer external topic partitions in stream reset tool Key: KAFKA-9042 URL: https://issues.apache.org/jira/browse/KAFKA-9042 Project: Kafka Issue

[jira] [Commented] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-8967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951597#comment-16951597 ] Matthias J. Sax commented on KAFKA-8967:

[jira] [Commented] (KAFKA-8671) NullPointerException occurs if topic associated with GlobalKTable changes

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

[jira] [Commented] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951596#comment-16951596 ] Matthias J. Sax commented on KAFKA-9022:

[jira] [Resolved] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8460. Resolution: Duplicate > Flaky Test

[jira] [Commented] (KAFKA-8264) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951595#comment-16951595 ] Matthias J. Sax commented on KAFKA-8264:

[jira] [Commented] (KAFKA-9041) Flaky Test LogCleanerIntegrationTest#testIsThreadFailed

[ https://issues.apache.org/jira/browse/KAFKA-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951589#comment-16951589 ] Matthias J. Sax commented on KAFKA-9041:

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951576#comment-16951576 ] Matthias J. Sax commented on KAFKA-8940:

[jira] [Created] (KAFKA-9041) Flaky Test LogCleanerIntegrationTest#testIsThreadFailed

Matthias J. Sax created KAFKA-9041: -- Summary: Flaky Test LogCleanerIntegrationTest#testIsThreadFailed Key: KAFKA-9041 URL: https://issues.apache.org/jira/browse/KAFKA-9041 Project: Kafka

[jira] [Commented] (KAFKA-8909) Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics

[ https://issues.apache.org/jira/browse/KAFKA-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951550#comment-16951550 ] Matthias J. Sax commented on KAFKA-8909:

[jira] [Commented] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

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

[jira] [Commented] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951519#comment-16951519 ] John Roesler commented on KAFKA-9032: - I'll pick this one up. I've reproduced the issue. The root

[jira] [Updated] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9000: Priority: Blocker (was: Major) > Flaky Test >

[jira] [Updated] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9000: Affects Version/s: 2.4.0 > Flaky Test >

[jira] [Assigned] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9032: --- Assignee: John Roesler > Serializer is invoked with null when foreignValue=null >

[jira] [Commented] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951517#comment-16951517 ] John Roesler commented on KAFKA-9006: - It isn't a true duplicate, but both flaky tests have the same

[jira] [Resolved] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9006. - Resolution: Duplicate > Flaky Test >

[jira] [Commented] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

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

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Created] (KAFKA-9040) Implement --all option when describing configs

Jason Gustafson created KAFKA-9040: -- Summary: Implement --all option when describing configs Key: KAFKA-9040 URL: https://issues.apache.org/jira/browse/KAFKA-9040 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9040) Implement --all option for describing configs

[ https://issues.apache.org/jira/browse/KAFKA-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-9040: --- Summary: Implement --all option for describing configs (was: Implement --all option when

[jira] [Commented] (KAFKA-9033) Change default client-id in consumer / producer to be more meaningful

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

[jira] [Updated] (KAFKA-8603) Document upgrade path

[ https://issues.apache.org/jira/browse/KAFKA-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8603: --- Priority: Blocker (was: Major) > Document upgrade path > - > >

[jira] [Updated] (KAFKA-8603) Document upgrade path

[ https://issues.apache.org/jira/browse/KAFKA-8603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8603: --- Fix Version/s: 2.4.0 > Document upgrade path > - > >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Parent: (was: KAFKA-8179) Issue Type: Improvement (was: Sub-task) >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER protocol & cleaning up task suspension in Streams rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate removing EAGER protocol & cleaning up task suspension in

[jira] [Updated] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

[ https://issues.apache.org/jira/browse/KAFKA-8767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8767: --- Parent: (was: KAFKA-8179) Issue Type: Improvement (was: Sub-task) >

[jira] [Commented] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

[ https://issues.apache.org/jira/browse/KAFKA-8767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951431#comment-16951431 ] Sophie Blee-Goldman commented on KAFKA-8767: see related: flaky test PR 

[jira] [Updated] (KAFKA-8767) Optimize StickyAssignor for Cooperative mode

[ https://issues.apache.org/jira/browse/KAFKA-8767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8767: --- Affects Version/s: 2.4.0 > Optimize StickyAssignor for Cooperative mode >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Fix Version/s: 3.0.0 > Investigate removing EAGER & cleaning up task suspension

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Affects Version/s: (was: 3.0.0) 2.4.0 > Investigate

[jira] [Assigned] (KAFKA-9033) Change default client-id in consumer / producer to be more meaningful

[ https://issues.apache.org/jira/browse/KAFKA-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-9033: -- Assignee: Jason Gustafson > Change default client-id in consumer / producer to be

[jira] [Commented] (KAFKA-9038) Allow creating partitions while partition reassignment is in progress

[ https://issues.apache.org/jira/browse/KAFKA-9038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951367#comment-16951367 ] Andrew Olson commented on KAFKA-9038: - Does it possibly matter if there's a consumer group subscribed

[jira] [Commented] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951334#comment-16951334 ] Bill Bejeck commented on KAFKA-9020: cherry-picked to 2.4 > Streams sub-topologies should be sorted

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951323#comment-16951323 ] Will James commented on KAFKA-8950: --- PR here [https://github.com/apache/kafka/pull/7511] Let me know

[jira] [Commented] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951316#comment-16951316 ] ASF GitHub Bot commented on KAFKA-9020: --- bbejeck commented on pull request #7495: KAFKA-9020:

[jira] [Resolved] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9020. Fix Version/s: 2.4.0 Resolution: Fixed > Streams sub-topologies should be

[jira] [Commented] (KAFKA-6144) Allow state stores to serve stale reads during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951312#comment-16951312 ] Vinoth Chandar commented on KAFKA-6144: --- [~NaviBrar] Thnx again,. responded on the mailing list.

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951229#comment-16951229 ] Will James commented on KAFKA-8950: --- Thanks, Yea it would be great to submit the PR assuming I can

[jira] [Assigned] (KAFKA-9024) org.apache.kafka.connect.transforms.ValueToKey throws NPE

[ https://issues.apache.org/jira/browse/KAFKA-9024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis reassigned KAFKA-9024: - Assignee: Nigel Liang > org.apache.kafka.connect.transforms.ValueToKey

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951187#comment-16951187 ] Rajini Sivaram commented on KAFKA-8950: --- Thanks [~thomaslee] [~mumrah] Are we likely to have

[jira] [Commented] (KAFKA-9039) Optimize replica fetching CPU utilization with large number of partitions

[ https://issues.apache.org/jira/browse/KAFKA-9039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951186#comment-16951186 ] Guozhang Wang commented on KAFKA-9039: -- Here's a first PR against this ticket:

[jira] [Created] (KAFKA-9039) Optimize replica fetching CPU utilization with large number of partitions

Guozhang Wang created KAFKA-9039: Summary: Optimize replica fetching CPU utilization with large number of partitions Key: KAFKA-9039 URL: https://issues.apache.org/jira/browse/KAFKA-9039 Project:

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951169#comment-16951169 ] Tom Lee commented on KAFKA-8950: Sounds good to me [~rsivaram], agree the fix seems trivial. To be clear,

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951159#comment-16951159 ] Rajini Sivaram commented on KAFKA-8950: --- We can either move `nodesWithPendingFetchRequests.add()`

[jira] [Created] (KAFKA-9038) Allow creating partitions while partition reassignment is in progress

Bob Barrett created KAFKA-9038: -- Summary: Allow creating partitions while partition reassignment is in progress Key: KAFKA-9038 URL: https://issues.apache.org/jira/browse/KAFKA-9038 Project: Kafka

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951140#comment-16951140 ] Tom Lee commented on KAFKA-8950: [~rsivaram] hm new flag? Couldn't we just move the

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951126#comment-16951126 ] Rajini Sivaram commented on KAFKA-8950: --- The scenario that [~wtjames] described is indeed possible.

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951100#comment-16951100 ] Tom Lee commented on KAFKA-8950: Oh wait, the RequestFutureCompletionHandlers can be invoked by the

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951096#comment-16951096 ] Tom Lee commented on KAFKA-8950: [~rsivaram] plaintext transport here too. Not sure we could provide the

[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=16951081#comment-16951081 ] Viktor Loosz commented on KAFKA-7656: - Hi, sorry for the late reply.  The problem seems to be solved

[jira] [Updated] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

[ https://issues.apache.org/jira/browse/KAFKA-9014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9014: - Fix Version/s: (was: 2.2.2) (was: 2.1.2) (was:

[jira] [Commented] (KAFKA-9016) Warn when log dir stopped serving replicas

[ https://issues.apache.org/jira/browse/KAFKA-9016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951022#comment-16951022 ] Viktor Somogyi-Vass commented on KAFKA-9016: Sure, feel free to grab it > Warn when log dir

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16951009#comment-16951009 ] Will James commented on KAFKA-8950: --- [~thomaslee] I guess I'm saying the listener is indeed called, but

[jira] [Updated] (KAFKA-8326) Add List Serde

[ https://issues.apache.org/jira/browse/KAFKA-8326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Daniyar Yeralin updated KAFKA-8326: --- Description: _This ticket proposes adding new {color:#4c9aff}ListSerializer{color} and

[jira] [Created] (KAFKA-9037) Java Out Of Memory(OOM) error encountered while deleting Kafka records using SASL designated port.

Akshath Karanam created KAFKA-9037: -- Summary: Java Out Of Memory(OOM) error encountered while deleting Kafka records using SASL designated port. Key: KAFKA-9037 URL:

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950898#comment-16950898 ] linking12 commented on KAFKA-4133: -- [~mjsax]  Is this resolved in 2.3 release?   > Provide a

[jira] [Commented] (KAFKA-8950) KafkaConsumer stops fetching

[ https://issues.apache.org/jira/browse/KAFKA-8950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950883#comment-16950883 ] Rajini Sivaram commented on KAFKA-8950: --- [~wtjames] [~thomaslee]  Thanks for reporting this issue.

[jira] [Commented] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory

[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950855#comment-16950855 ] linking12 commented on KAFKA-8898: -- [~rachana_prajapati]   

[jira] [Created] (KAFKA-9036) Allow kafka auth acls with match pattern

Pradeep Bansal created KAFKA-9036: - Summary: Allow kafka auth acls with match pattern Key: KAFKA-9036 URL: https://issues.apache.org/jira/browse/KAFKA-9036 Project: Kafka Issue Type: