[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

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

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845478#comment-16845478 ] Omkar Mestry commented on KAFKA-7245: - So we need to update only the tests which have put() call with

[jira] [Created] (KAFKA-8405) Remove deprecated preferred leader RPC and Command

Jose Armando Garcia Sancio created KAFKA-8405: - Summary: Remove deprecated preferred leader RPC and Command Key: KAFKA-8405 URL: https://issues.apache.org/jira/browse/KAFKA-8405 Project:

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845381#comment-16845381 ] Sophie Blee-Goldman commented on KAFKA-7994: Hi [~Yohan123], I think we need to be careful in

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845338#comment-16845338 ] Richard Yu commented on KAFKA-7994: --- [~guozhang] [~mjsax] and [~vvcephei] I created a KIP for this

[jira] [Commented] (KAFKA-8365) Protocol and consumer support for follower fetching

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

[jira] [Assigned] (KAFKA-2939) Make AbstractConfig.logUnused() tunable for clients

[ https://issues.apache.org/jira/browse/KAFKA-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rens Groothuijsen reassigned KAFKA-2939: Assignee: Rens Groothuijsen > Make AbstractConfig.logUnused() tunable for clients

[jira] [Resolved] (KAFKA-7565) NPE in KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7565. --- Resolution: Duplicate Fix Version/s: 2.3.0 > NPE in KafkaConsumer >

[jira] [Resolved] (KAFKA-8052) Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request

[ https://issues.apache.org/jira/browse/KAFKA-8052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-8052. --- Resolution: Fixed Reviewer: Jason Gustafson Fix Version/s: 2.3.0 >

[jira] [Commented] (KAFKA-8052) Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request

[ https://issues.apache.org/jira/browse/KAFKA-8052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845248#comment-16845248 ] ASF GitHub Bot commented on KAFKA-8052: --- rajinisivaram commented on pull request #6582: KAFKA-8052;

[jira] [Created] (KAFKA-8404) Authorization header is not passed in Connect when forwarding REST requests

Robert Yokota created KAFKA-8404: Summary: Authorization header is not passed in Connect when forwarding REST requests Key: KAFKA-8404 URL: https://issues.apache.org/jira/browse/KAFKA-8404 Project:

[jira] [Commented] (KAFKA-8199) ClassCastException when trying to groupBy after suppress

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

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845161#comment-16845161 ] Matthias J. Sax commented on KAFKA-7245: No problem [~panuwat.anawatmongk...@gmail.com]! Thanks

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845160#comment-16845160 ] Panuwat Anawatmongkhon commented on KAFKA-7245: --- [~mjsax] [~omanges] I forgot that I have

[jira] [Assigned] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panuwat Anawatmongkhon reassigned KAFKA-7245: - Assignee: Omkar Mestry (was: Panuwat Anawatmongkhon) > Deprecate

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845126#comment-16845126 ] Matthias J. Sax commented on KAFKA-7245: Well. [~panuwat.anawatmongk...@gmail.com] wanted to work

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

[ https://issues.apache.org/jira/browse/KAFKA-8286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jose Armando Garcia Sancio updated KAFKA-8286: -- Description: Tracking issue for implementing KIP-460. Tasks: # [Done]

[jira] [Commented] (KAFKA-8315) Historical join issues

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

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845029#comment-16845029 ] Gary Russell commented on KAFKA-8195: - {quote} How did you end up in this situation? {quote} Once I

[jira] [Commented] (KAFKA-8265) Connect Client Config Override policy

[ https://issues.apache.org/jira/browse/KAFKA-8265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845014#comment-16845014 ] ASF GitHub Bot commented on KAFKA-8265: --- rhauch commented on pull request #6776: KAFKA-8265 : Match

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844958#comment-16844958 ] Pavel Savov commented on KAFKA-8367: [~guozhang] Yes, the commit you mentioned was included in the

[jira] [Created] (KAFKA-8403) Suppress needs a Materialized variant

John Roesler created KAFKA-8403: --- Summary: Suppress needs a Materialized variant Key: KAFKA-8403 URL: https://issues.apache.org/jira/browse/KAFKA-8403 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8152) Offline partition state not propagated by controller

[ https://issues.apache.org/jira/browse/KAFKA-8152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8152. -- Resolution: Duplicate > Offline partition state not propagated by controller >

[jira] [Commented] (KAFKA-3143) inconsistent state in ZK when all replicas are dead

[ https://issues.apache.org/jira/browse/KAFKA-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844948#comment-16844948 ] ASF GitHub Bot commented on KAFKA-3143: --- omkreddy commented on pull request #5041: KAFKA-3143:

[jira] [Resolved] (KAFKA-3143) inconsistent state in ZK when all replicas are dead

[ https://issues.apache.org/jira/browse/KAFKA-3143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3143. -- Resolution: Fixed Fix Version/s: 2.3.0 Issue resolved by pull request 5041

[jira] [Created] (KAFKA-8402) bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB

Vyacheslav Stepanov created KAFKA-8402: -- Summary: bin/kafka-preferred-replica-election.sh fails if generated json is bigger than 1MB Key: KAFKA-8402 URL: https://issues.apache.org/jira/browse/KAFKA-8402

[jira] [Resolved] (KAFKA-8320) Connect Error handling is using the RetriableException from common package

[ https://issues.apache.org/jira/browse/KAFKA-8320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8320. -- Resolution: Fixed Fix Version/s: 2.2.1 2.1.2 2.3.0

[jira] [Commented] (KAFKA-3096) Leader is not set to -1 when it is shutdown if followers are down

[ https://issues.apache.org/jira/browse/KAFKA-3096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844876#comment-16844876 ] ASF GitHub Bot commented on KAFKA-3096: --- ijuma commented on pull request #765: KAFKA-3096; Leader

[jira] [Commented] (KAFKA-3932) Consumer fails to consume in a round robin fashion

[ https://issues.apache.org/jira/browse/KAFKA-3932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844818#comment-16844818 ] ASF GitHub Bot commented on KAFKA-3932: --- chienhsingwu commented on pull request #5838: KAFKA-3932 -

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844764#comment-16844764 ] Omkar Mestry commented on KAFKA-7245: - [~mjsax] Please add me to the contributors list, so that I can

[jira] [Updated] (KAFKA-8401) consumer.poll(Duration.ofMillis(100)) blocking

[ https://issues.apache.org/jira/browse/KAFKA-8401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] leishuiyu updated KAFKA-8401: - Description: # this is code {code:java} public class Consumer extends Thread { KafkaConsumer

[jira] [Created] (KAFKA-8401) consumer.poll(Duration.ofMillis(100)) blocking

leishuiyu created KAFKA-8401: Summary: consumer.poll(Duration.ofMillis(100)) blocking Key: KAFKA-8401 URL: https://issues.apache.org/jira/browse/KAFKA-8401 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-7991) Add StreamsUpgradeTest for 2.2 release

[ https://issues.apache.org/jira/browse/KAFKA-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844670#comment-16844670 ] Matthias J. Sax commented on KAFKA-7991: [~vvcephei] Seems this overlaps with 

[jira] [Commented] (KAFKA-7983) supporting replication.throttled.replicas in dynamic broker configuration

[ https://issues.apache.org/jira/browse/KAFKA-7983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844660#comment-16844660 ] Rahul Agarwal commented on KAFKA-7983: -- I am working on it. Will submit the patch once ready. >

[jira] [Commented] (KAFKA-8195) Unstable Producer After Send Failure in Transaction

[ https://issues.apache.org/jira/browse/KAFKA-8195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844622#comment-16844622 ] Viktor Somogyi-Vass commented on KAFKA-8195: Yea, min.insync.replicas is a similar situation.