[jira] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084602#comment-17084602 ] Théo commented on KAFKA-7077: - i'm going to take a close look on it ! > KIP-318: Make Kafka

[jira] [Commented] (KAFKA-9543) Consumer offset reset after new segment rolling

[ https://issues.apache.org/jira/browse/KAFKA-9543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084605#comment-17084605 ] Jason Gustafson commented on KAFKA-9543: In KAFKA-9838, I fixed what I thought wa

[jira] [Assigned] (KAFKA-9320) Enable TLSv1.3 by default and disable some of the older protocols

[ https://issues.apache.org/jira/browse/KAFKA-9320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov reassigned KAFKA-9320: -- Assignee: (was: Nikolay Izhikov) > Enable TLSv1.3 by default and disable some of t

[jira] [Comment Edited] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084602#comment-17084602 ] Théo edited comment on KAFKA-7077 at 4/16/20, 9:04 AM: --- i'm going t

[jira] [Updated] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

[ https://issues.apache.org/jira/browse/KAFKA-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9230: - Fix Version/s: 2.5.0 > Change User Customizable Metrics API in StreamsMetrics interface > ---

[jira] [Resolved] (KAFKA-9117) Add active-process-ratio Metric

[ https://issues.apache.org/jira/browse/KAFKA-9117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-9117. -- Fix Version/s: (was: 2.6.0) Resolution: Duplicate > Add active-process-ratio Metric

[jira] [Commented] (KAFKA-9590) Add configuration to limit number of partitions

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

[jira] [Commented] (KAFKA-9137) Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions

[ https://issues.apache.org/jira/browse/KAFKA-9137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084756#comment-17084756 ] Philip Bourke commented on KAFKA-9137: -- What version is this fixed in? 2.5 was relea

[jira] [Created] (KAFKA-9879) How kafka deletes tombstone messages?

VIkram created KAFKA-9879: - Summary: How kafka deletes tombstone messages? Key: KAFKA-9879 URL: https://issues.apache.org/jira/browse/KAFKA-9879 Project: Kafka Issue Type: Bug Reporter: V

[jira] [Updated] (KAFKA-9879) How kafka deletes tombstone messages?

[ https://issues.apache.org/jira/browse/KAFKA-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] VIkram updated KAFKA-9879: -- Description: I was able to delete records in kafka using tombstone messages after few attempts. However the al

[jira] [Created] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

Nicolas Carlot created KAFKA-9880: - Summary: Error while range compacting during bulk loading of FIFO compacted RocksDB Store Key: KAFKA-9880 URL: https://issues.apache.org/jira/browse/KAFKA-9880 Proj

[jira] [Updated] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Carlot updated KAFKA-9880: -- Description: When restoring a non empty RocksDB state store, if it is customized to use FIFOCo

[jira] [Updated] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Carlot updated KAFKA-9880: -- Description:   When restoring a non empty RocksDB state store, if it is customized to use FIF

[jira] [Updated] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Carlot updated KAFKA-9880: -- Description:   When restoring a non empty RocksDB state store, if it is customized to use FIF

[jira] [Updated] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Carlot updated KAFKA-9880: -- Description:   When restoring a non empty RocksDB state store, if it is customized to use FIF

[jira] [Updated] (KAFKA-9880) Error while range compacting during bulk loading of FIFO compacted RocksDB Store

[ https://issues.apache.org/jira/browse/KAFKA-9880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolas Carlot updated KAFKA-9880: -- Description:   When restoring a non empty RocksDB state store, if it is customized to use FIF

[jira] [Commented] (KAFKA-9854) Re-authenticating causes mismatched parse of response

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

[jira] [Resolved] (KAFKA-9854) Re-authenticating causes mismatched parse of response

[ https://issues.apache.org/jira/browse/KAFKA-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9854. --- Fix Version/s: 2.5.1 2.6.0 Reviewer: Rajini Sivaram Resolut

[jira] [Commented] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084833#comment-17084833 ] Théo commented on KAFKA-7077: - I just submit a PR with those little changes and i'm waiting t

[jira] [Comment Edited] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084833#comment-17084833 ] Théo edited comment on KAFKA-7077 at 4/16/20, 12:48 PM: I just su

[jira] [Comment Edited] (KAFKA-7077) KIP-318: Make Kafka Connect Source idempotent

[ https://issues.apache.org/jira/browse/KAFKA-7077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084833#comment-17084833 ] Théo edited comment on KAFKA-7077 at 4/16/20, 12:48 PM: I just su

[jira] [Created] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of a Intergration Test

Bruno Cadonna created KAFKA-9881: Summary: Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of a Intergration Test Key: KAFKA-9881 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Updated] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-9881: - Summary: Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an

[jira] [Commented] (KAFKA-9881) Verify whether RocksDBMetrics Get Measurements from RocksDB in a Unit Test instead of an Intergration Test

[ https://issues.apache.org/jira/browse/KAFKA-9881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084881#comment-17084881 ] ASF GitHub Bot commented on KAFKA-9881: --- cadonna commented on pull request #8501: K

[jira] [Commented] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17084985#comment-17084985 ] zhongyushuo commented on KAFKA-7500: [~ryannedolan] I got your point. Thanks for your

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Summary: Transactional Producer could pre-add partitions (was: Transactional Producer could add part

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Description: As of today, the Producer transaction manager bookkeeps the partitions involved with cu

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Labels: need-kip (was: ) > Transactional Producer could pre-add partitions > ---

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Component/s: producer > Transactional Producer could pre-add partitions > --

[jira] [Created] (KAFKA-9882) Add Block getAssignments()

Jesse Anderson created KAFKA-9882: - Summary: Add Block getAssignments() Key: KAFKA-9882 URL: https://issues.apache.org/jira/browse/KAFKA-9882 Project: Kafka Issue Type: New Feature

[jira] [Commented] (KAFKA-9796) Broker shutdown could be stuck forever under certain conditions

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

[jira] [Resolved] (KAFKA-9796) Broker shutdown could be stuck forever under certain conditions

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

[jira] [Assigned] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9860: -- Assignee: (was: Boyang Chen) > Transactional Producer could pre-add partitions > -

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085121#comment-17085121 ] John Roesler commented on KAFKA-9224: - Hi [~bchen225242] , this ticket has just come

[jira] [Comment Edited] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085121#comment-17085121 ] John Roesler edited comment on KAFKA-9224 at 4/16/20, 5:51 PM:

[jira] [Updated] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8856: --- Description: With KIP-444 the tag names and names of streams metrics change. To allow users

[jira] [Updated] (KAFKA-8856) Add Streams Config for Backward-compatible Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8856: --- Labels: kip (was: ) > Add Streams Config for Backward-compatible Metrics > -

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085141#comment-17085141 ] Guozhang Wang commented on KAFKA-9224: -- Since it is considered targeting the same is

[jira] [Updated] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9224: --- Description: Currently under EOS, the uncommitted write could be reflected in the state store before

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085163#comment-17085163 ] Boyang Chen commented on KAFKA-9224: [~vvcephei] [~guozhang]Yea, it's a typo, and I j

[jira] [Commented] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085166#comment-17085166 ] Guozhang Wang commented on KAFKA-9860: -- I think this is a good idea. Probably we sho

[jira] [Commented] (KAFKA-9878) Block EndTxn call until the txn markers are committed

[ https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085171#comment-17085171 ] Guozhang Wang commented on KAFKA-9878: -- The original rationale is that if after comm

[jira] [Updated] (KAFKA-9860) Transactional Producer could pre-add partitions

[ https://issues.apache.org/jira/browse/KAFKA-9860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9860: --- Description: As of today, the Producer transaction manager bookkeeps the partitions involved with cu

[jira] [Assigned] (KAFKA-9066) Kafka Connect JMX : source & sink task metrics missing for tasks in failed state

[ https://issues.apache.org/jira/browse/KAFKA-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-9066: Assignee: Chris Egerton > Kafka Connect JMX : source & sink task metrics missing for tasks

[jira] [Commented] (KAFKA-9066) Kafka Connect JMX : source & sink task metrics missing for tasks in failed state

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

[jira] [Commented] (KAFKA-9867) Log cleaner throws InvalidOffsetException for some partitions

[ https://issues.apache.org/jira/browse/KAFKA-9867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085254#comment-17085254 ] Bradley Peterson commented on KAFKA-9867: - After upgrade to 2.4.1, I see the same

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085270#comment-17085270 ] John Roesler commented on KAFKA-9224: - Thanks, all, I've re-read this issue, and also

[jira] [Comment Edited] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085270#comment-17085270 ] John Roesler edited comment on KAFKA-9224 at 4/16/20, 9:32 PM:

[jira] [Updated] (KAFKA-9753) Add task-level active-process-ratio to Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-9753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9753: --- Description: This is described as part of KIP-444 (which is mostly done in 2.4 / 2.5). [http

[jira] [Updated] (KAFKA-9230) Change User Customizable Metrics API in StreamsMetrics interface

[ https://issues.apache.org/jira/browse/KAFKA-9230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9230: --- Labels: kip (was: ) > Change User Customizable Metrics API in StreamsMetrics interface > ---

[jira] [Updated] (KAFKA-9753) Add task-level active-process-ratio to Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-9753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-9753: --- Labels: kip (was: ) > Add task-level active-process-ratio to Streams metrics > -

[jira] [Created] (KAFKA-9883) Connect request to restart task can result in IllegalArgumentError: "uriTemplate" parameter is null

Randall Hauch created KAFKA-9883: Summary: Connect request to restart task can result in IllegalArgumentError: "uriTemplate" parameter is null Key: KAFKA-9883 URL: https://issues.apache.org/jira/browse/KAFKA-9883

[jira] [Commented] (KAFKA-9224) State store should not see uncommitted transaction result

[ https://issues.apache.org/jira/browse/KAFKA-9224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085311#comment-17085311 ] Guozhang Wang commented on KAFKA-9224: -- My understanding for this JIRA is more relat

[jira] [Updated] (KAFKA-9883) Connect request to restart task can result in IllegalArgumentError: "uriTemplate" parameter is null

[ https://issues.apache.org/jira/browse/KAFKA-9883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9883: - Priority: Minor (was: Major) > Connect request to restart task can result in IllegalArgumentErro

[jira] [Commented] (KAFKA-9298) Reuse of a mapped stream causes an Invalid Topology

[ https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085398#comment-17085398 ] ASF GitHub Bot commented on KAFKA-9298: --- bbejeck commented on pull request #8504: K

[jira] [Commented] (KAFKA-9863) update the deprecated --zookeeper option in the documentation into --bootstrap-server

[ https://issues.apache.org/jira/browse/KAFKA-9863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17085487#comment-17085487 ] Luke Chen commented on KAFKA-9863: -- PR: https://github.com/apache/kafka/pull/8482 > upd