[jira] [Updated] (KAFKA-8447) New Metric to Measure Number of Tasks on a Connector

[ https://issues.apache.org/jira/browse/KAFKA-8447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cyrus Vafadari updated KAFKA-8447: -- Summary: New Metric to Measure Number of Tasks on a Connector (was: Add Connector-level metric

[jira] [Created] (KAFKA-8447) Add Connector-level metric to count tasks

Cyrus Vafadari created KAFKA-8447: - Summary: Add Connector-level metric to count tasks Key: KAFKA-8447 URL: https://issues.apache.org/jira/browse/KAFKA-8447 Project: Kafka Issue Type: New Fea

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851493#comment-16851493 ] Sagar Rao commented on KAFKA-7995: -- Hey [~suryateja...@gmail.com] apparently even I am n

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8446: --- Component/s: streams > KStream restoration will crash with NPE when the record value is null

[jira] [Commented] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

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

[jira] [Commented] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851443#comment-16851443 ] ASF GitHub Bot commented on KAFKA-8001: --- soondenana commented on pull request #6841

[jira] [Commented] (KAFKA-8418) Connect System tests are not waiting for REST resources to be registered

[ https://issues.apache.org/jira/browse/KAFKA-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851439#comment-16851439 ] ASF GitHub Bot commented on KAFKA-8418: --- avocader commented on pull request #6840:

[jira] [Commented] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851438#comment-16851438 ] ASF GitHub Bot commented on KAFKA-8001: --- soondenana commented on pull request #6839

[jira] [Commented] (KAFKA-8001) Fetch from future replica stalls when local replica becomes a leader

[ https://issues.apache.org/jira/browse/KAFKA-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851436#comment-16851436 ] ASF GitHub Bot commented on KAFKA-8001: --- soondenana commented on pull request #6839

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Fix Version/s: (was: 2.3.0) > KStream restoration will crash with NPE when the record value is nu

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Fix Version/s: 2.3.0 > KStream restoration will crash with NPE when the record value is null > --

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Affects Version/s: 2.3.0 > KStream restoration will crash with NPE when the record value is null > --

[jira] [Created] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

Boyang Chen created KAFKA-8446: -- Summary: KStream restoration will crash with NPE when the record value is null Key: KAFKA-8446 URL: https://issues.apache.org/jira/browse/KAFKA-8446 Project: Kafka

[jira] [Commented] (KAFKA-7703) KafkaConsumer.position may return a wrong offset after "seekToEnd" is called

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

[jira] [Commented] (KAFKA-8328) Kafka smooth expansion

[ https://issues.apache.org/jira/browse/KAFKA-8328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851303#comment-16851303 ] Richard Yu commented on KAFKA-8328: --- Hi [~LordChen] I believe for a change like this, s

[jira] [Commented] (KAFKA-8377) KTable#transformValue might lead to incorrect result in joins

[ https://issues.apache.org/jira/browse/KAFKA-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851300#comment-16851300 ] Richard Yu commented on KAFKA-8377: --- cc [~mjsax] How hard would this bug be when tackle

[jira] [Commented] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851262#comment-16851262 ] SuryaTeja Duggi commented on KAFKA-7995: [~sagarrao] Can I work along with you on

[jira] [Assigned] (KAFKA-8398) NPE when unmapping files after moving log directories using AlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-8398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan reassigned KAFKA-8398: - Assignee: Justine Olshan > NPE when unmapping files after moving log directories using

[jira] [Commented] (KAFKA-8286) KIP-460 Admin Leader Election RPC

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

[jira] [Assigned] (KAFKA-7995) Augment singleton protocol type to list for Kafka Consumer

[ https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-7995: Assignee: Sagar Rao > Augment singleton protocol type to list for Kafka Consumer > -

[jira] [Commented] (KAFKA-7206) Enable batching in FindCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16851007#comment-16851007 ] Sagar Rao commented on KAFKA-7206: -- I see. Probably I would also park it for now and loo

[jira] [Commented] (KAFKA-8165) Streams task causes Out Of Memory after connection issues and store restoration

[ https://issues.apache.org/jira/browse/KAFKA-8165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850739#comment-16850739 ] Di Campo commented on KAFKA-8165: - Some things we did to help:  - Allocating more memory