[jira] [Updated] (KAFKA-17941) TransactionStateManager.loadTransactionMetadata method may get stuck in an infinite loop

[ https://issues.apache.org/jira/browse/KAFKA-17941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang updated KAFKA-17941: -- Description: When loading transaction metadata from a transaction log partition, if the parti

[jira] [Created] (KAFKA-17941) TransactionStateManager.loadTransactionMetadata method may get stuck in an infinite loop

Vincent Jiang created KAFKA-17941: - Summary: TransactionStateManager.loadTransactionMetadata method may get stuck in an infinite loop Key: KAFKA-17941 URL: https://issues.apache.org/jira/browse/KAFKA-17941

[jira] [Assigned] (KAFKA-15375) When running in KRaft mode, LogManager may creates CleanShutdown file by mistake

[ https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang reassigned KAFKA-15375: - Assignee: Vincent Jiang > When running in KRaft mode, LogManager may creates CleanShutd

[jira] [Updated] (KAFKA-15375) When running in KRaft mode, LogManager may creates CleanShutdown file by mistake

[ https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang updated KAFKA-15375: -- Description: Consider following sequence when running Kafka in KRaft mode: # A partition log

[jira] [Updated] (KAFKA-15375) When running in KRaft mode, LogManager may creates CleanShutdown file by mistake

[ https://issues.apache.org/jira/browse/KAFKA-15375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang updated KAFKA-15375: -- Description: Consider following sequence when running Kafka in KRaft mode: # A partition log

[jira] [Created] (KAFKA-15375) When running in KRaft mode, LogManager may creates CleanShutdown file by mistake

Vincent Jiang created KAFKA-15375: - Summary: When running in KRaft mode, LogManager may creates CleanShutdown file by mistake Key: KAFKA-15375 URL: https://issues.apache.org/jira/browse/KAFKA-15375 P

[jira] [Created] (KAFKA-14497) LastStableOffset is advanced prematurely when a log is reopened.

Vincent Jiang created KAFKA-14497: - Summary: LastStableOffset is advanced prematurely when a log is reopened. Key: KAFKA-14497 URL: https://issues.apache.org/jira/browse/KAFKA-14497 Project: Kafka

[jira] [Commented] (KAFKA-14347) deleted records may be kept unexpectedly when leader changes while adding a new replica

[ https://issues.apache.org/jira/browse/KAFKA-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627365#comment-17627365 ] Vincent Jiang commented on KAFKA-14347: --- Related issue: https://issues.apache.org/

[jira] [Created] (KAFKA-14347) deleted records may be kept unexpectedly when leader changes while adding a new replica

Vincent Jiang created KAFKA-14347: - Summary: deleted records may be kept unexpectedly when leader changes while adding a new replica Key: KAFKA-14347 URL: https://issues.apache.org/jira/browse/KAFKA-14347

[jira] [Commented] (KAFKA-14096) Race Condition in Log Rolling Leading to Disk Failure

[ https://issues.apache.org/jira/browse/KAFKA-14096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17579155#comment-17579155 ] Vincent Jiang commented on KAFKA-14096: --- I have two questions about this issue: 1.

[jira] [Updated] (KAFKA-14151) Add additional validation to protect on-disk log segment data from being corrupted

[ https://issues.apache.org/jira/browse/KAFKA-14151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang updated KAFKA-14151: -- Priority: Major (was: Minor) > Add additional validation to protect on-disk log segment data

[jira] [Created] (KAFKA-14151) Add additional validation to protect on-disk log segment data from being corrupted

Vincent Jiang created KAFKA-14151: - Summary: Add additional validation to protect on-disk log segment data from being corrupted Key: KAFKA-14151 URL: https://issues.apache.org/jira/browse/KAFKA-14151

[jira] [Updated] (KAFKA-14151) Add additional validation to protect on-disk log segment data from being corrupted

[ https://issues.apache.org/jira/browse/KAFKA-14151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vincent Jiang updated KAFKA-14151: -- Priority: Minor (was: Major) > Add additional validation to protect on-disk log segment data

[jira] [Created] (KAFKA-14005) LogCleaner doesn't clean log if there is no dirty range

Vincent Jiang created KAFKA-14005: - Summary: LogCleaner doesn't clean log if there is no dirty range Key: KAFKA-14005 URL: https://issues.apache.org/jira/browse/KAFKA-14005 Project: Kafka Iss

[jira] [Created] (KAFKA-13717) KafkaConsumer.close throws authorization exception even when commit offsets is empty

Vincent Jiang created KAFKA-13717: - Summary: KafkaConsumer.close throws authorization exception even when commit offsets is empty Key: KAFKA-13717 URL: https://issues.apache.org/jira/browse/KAFKA-13717

[jira] [Created] (KAFKA-13706) org.apache.kafka.test.MockSelector doesn't remove closed connections from its 'ready' field

Vincent Jiang created KAFKA-13706: - Summary: org.apache.kafka.test.MockSelector doesn't remove closed connections from its 'ready' field Key: KAFKA-13706 URL: https://issues.apache.org/jira/browse/KAFKA-13706

[jira] [Created] (KAFKA-13461) KafkaController stops functioning as active controller after ZooKeeperClient auth failure

Vincent Jiang created KAFKA-13461: - Summary: KafkaController stops functioning as active controller after ZooKeeperClient auth failure Key: KAFKA-13461 URL: https://issues.apache.org/jira/browse/KAFKA-13461

[jira] [Created] (KAFKA-13305) NullPointerException in LogCleanerManager "uncleanable-bytes" gauge

Vincent Jiang created KAFKA-13305: - Summary: NullPointerException in LogCleanerManager "uncleanable-bytes" gauge Key: KAFKA-13305 URL: https://issues.apache.org/jira/browse/KAFKA-13305 Project: Kafka