[jira] [Commented] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580879#comment-16580879 ] Alastair Munro commented on KAFKA-7282: --- This looks interesting:

[jira] [Commented] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580819#comment-16580819 ] ASF GitHub Bot commented on KAFKA-7288: --- rajinisivaram closed pull request #5504: KAFKA-7288: Fix

[jira] [Resolved] (KAFKA-7288) Transient failure in SslSelectorTest.testCloseConnectionInClosingState

[ https://issues.apache.org/jira/browse/KAFKA-7288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7288. --- Resolution: Fixed Reviewer: Jun Rao Fix Version/s: 2.1.0 > Transient failure

[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=16580836#comment-16580836 ] M. Manna commented on KAFKA-1194: - [~haraldk] not sure about this jdk bug The issue happens mainly on

[jira] [Commented] (KAFKA-7282) Failed to read `log header` from file channel

[ https://issues.apache.org/jira/browse/KAFKA-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580861#comment-16580861 ] Alastair Munro commented on KAFKA-7282: --- I think this might be related to glusterfs; the underlying

[jira] [Reopened] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

[ https://issues.apache.org/jira/browse/KAFKA-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reopened KAFKA-7119: --- There was a test failure with the 1.0 build. It looks like we need to handle retriable Kerberos

[jira] [Commented] (KAFKA-7119) Intermittent test failure with GSSAPI authentication failure

[ https://issues.apache.org/jira/browse/KAFKA-7119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580865#comment-16580865 ] ASF GitHub Bot commented on KAFKA-7119: --- rajinisivaram opened a new pull request #5509: KAFKA-7119:

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581568#comment-16581568 ] Luca Pette commented on KAFKA-7269: --- [~vvcephei] Very happy to contribute in any way (writing docs is a

[jira] [Commented] (KAFKA-7269) KStream.merge is not documented

[ https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581563#comment-16581563 ] ASF GitHub Bot commented on KAFKA-7269: --- lucapette opened a new pull request #5512: KAFKA-7269: Add

[jira] [Updated] (KAFKA-7198) Enhance KafkaStreams start method javadoc

[ https://issues.apache.org/jira/browse/KAFKA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7198: --- Component/s: streams > Enhance KafkaStreams start method javadoc >

[jira] [Updated] (KAFKA-7198) Enhance KafkaStreams start method javadoc

[ https://issues.apache.org/jira/browse/KAFKA-7198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7198: --- Labels: newbie (was: newbie,) > Enhance KafkaStreams start method javadoc >

[jira] [Resolved] (KAFKA-6974) Changes the interaction between request handler threads and fetcher threads into an ASYNC model

[ https://issues.apache.org/jira/browse/KAFKA-6974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Wang resolved KAFKA-6974. --- Resolution: Won't Fix > Changes the interaction between request handler threads and fetcher threads

[jira] [Created] (KAFKA-7296) Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit

Jason Gustafson created KAFKA-7296: -- Summary: Producer should handler COORDINATOR_LOADING error in TxnOffsetCommit Key: KAFKA-7296 URL: https://issues.apache.org/jira/browse/KAFKA-7296 Project:

[jira] [Commented] (KAFKA-7284) Producer getting fenced may cause Streams to shut down

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

[jira] [Commented] (KAFKA-7284) Producer getting fenced may cause Streams to shut down

[ https://issues.apache.org/jira/browse/KAFKA-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581572#comment-16581572 ] ASF GitHub Bot commented on KAFKA-7284: --- vvcephei opened a new pull request #5513: KAFKA-7284:

[jira] [Updated] (KAFKA-7296) Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-7296: --- Summary: Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit (was: Producer

[jira] [Commented] (KAFKA-7296) Producer should handle COORDINATOR_LOADING error in TxnOffsetCommit

[ https://issues.apache.org/jira/browse/KAFKA-7296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581680#comment-16581680 ] ASF GitHub Bot commented on KAFKA-7296: --- hachikuji opened a new pull request #5514: KAFKA-7296;

[jira] [Created] (KAFKA-7297) Both read/write access to Log.segments should be protected by lock

Dong Lin created KAFKA-7297: --- Summary: Both read/write access to Log.segments should be protected by lock Key: KAFKA-7297 URL: https://issues.apache.org/jira/browse/KAFKA-7297 Project: Kafka

[jira] [Updated] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6998: --- Description: Users can disable caching globally by setting the cache size to zero in their

[jira] [Assigned] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6998: -- Assignee: Guozhang Wang > Remove caching wrapper stores if cache-size is configured

[jira] [Updated] (KAFKA-6998) Remove caching wrapper stores if cache-size is configured to zero bytes

[ https://issues.apache.org/jira/browse/KAFKA-6998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6998: --- Labels: kip (was: ) > Remove caching wrapper stores if cache-size is configured to zero

[jira] [Assigned] (KAFKA-7299) batch LeaderAndIsr requests during auto preferred leader election

[ https://issues.apache.org/jira/browse/KAFKA-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huxihx reassigned KAFKA-7299: - Assignee: huxihx > batch LeaderAndIsr requests during auto preferred leader election >

[jira] [Commented] (KAFKA-7299) batch LeaderAndIsr requests during auto preferred leader election

[ https://issues.apache.org/jira/browse/KAFKA-7299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581848#comment-16581848 ] ASF GitHub Bot commented on KAFKA-7299: --- huxihx opened a new pull request #5515: KAFKA-7299: Batch

[jira] [Commented] (KAFKA-7291) kafka-console-consumer.sh waits on inexistent topic

[ https://issues.apache.org/jira/browse/KAFKA-7291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581803#comment-16581803 ] huxihx commented on KAFKA-7291: --- With the latest build, ConsoleConsumer complains `Error while fetching

[jira] [Created] (KAFKA-7299) batch LeaderAndIsr requests during auto preferred leader election

Jun Rao created KAFKA-7299: -- Summary: batch LeaderAndIsr requests during auto preferred leader election Key: KAFKA-7299 URL: https://issues.apache.org/jira/browse/KAFKA-7299 Project: Kafka Issue

[jira] [Updated] (KAFKA-7284) Producer getting fenced may cause Streams to shut down

[ https://issues.apache.org/jira/browse/KAFKA-7284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7284: --- Fix Version/s: 1.1.2 > Producer getting fenced may cause Streams to shut down >

[jira] [Created] (KAFKA-7298) Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer

Jason Gustafson created KAFKA-7298: -- Summary: Concurrent DeleteRecords can lead to fatal OutOfSequence error in producer Key: KAFKA-7298 URL: https://issues.apache.org/jira/browse/KAFKA-7298

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581836#comment-16581836 ] Bertus Greeff commented on KAFKA-7061: -- This enhancement would solve a problem that is hard and

[jira] [Commented] (KAFKA-7285) Streams should be more fencing-sensitive during task suspension under EOS

[ https://issues.apache.org/jira/browse/KAFKA-7285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581760#comment-16581760 ] ASF GitHub Bot commented on KAFKA-7285: --- mjsax closed pull request #5501: KAFKA-7285: Create new

[jira] [Updated] (KAFKA-7285) Streams should be more fencing-sensitive during task suspension under EOS

[ https://issues.apache.org/jira/browse/KAFKA-7285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7285: --- Fix Version/s: 1.1.2 > Streams should be more fencing-sensitive during task suspension under

[jira] [Commented] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

[ https://issues.apache.org/jira/browse/KAFKA-7277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581971#comment-16581971 ] Nikolay Izhikov commented on KAFKA-7277: Hello, [~vvcephei]. > Ideally, we would get this change

[jira] [Commented] (KAFKA-7114) Kafka Not sending few partitions messages to consumers

[ https://issues.apache.org/jira/browse/KAFKA-7114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16581941#comment-16581941 ] Gnanasoundari commented on KAFKA-7114: -- I dont see any logs in consumer to indicate the message has

[jira] [Assigned] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Attila Sasvari reassigned KAFKA-7289: - Assignee: Attila Sasvari > Performance tools should allow user to specify output type >

[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=16580774#comment-16580774 ] Harald Kirsch commented on KAFKA-1194: -- As far as I understand the issue, it might have to do with

[jira] [Commented] (KAFKA-7289) Performance tools should allow user to specify output type

[ https://issues.apache.org/jira/browse/KAFKA-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16580792#comment-16580792 ] Attila Sasvari commented on KAFKA-7289: --- - I will start the KIP soon. It might be enough to deal