[jira] [Comment Edited] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2020-04-10 Thread Jeff Widman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081137#comment-17081137 ] Jeff Widman edited comment on KAFKA-4668 at 4/11/20, 4:44 AM: -- Going to try

[jira] [Comment Edited] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2020-04-10 Thread Jeff Widman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081137#comment-17081137 ] Jeff Widman edited comment on KAFKA-4668 at 4/11/20, 4:44 AM: -- Going to try

[jira] [Commented] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2020-04-10 Thread Jeff Widman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081137#comment-17081137 ] Jeff Widman commented on KAFKA-4668: Going to try to get this across the line, three years later. :D

[jira] [Commented] (KAFKA-9765) Could not add partitions to transaction due to errors

2020-04-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081060#comment-17081060 ] Guozhang Wang commented on KAFKA-9765: -- Hello [~waykarp] I looked your uploaded stack trace,

[jira] [Commented] (KAFKA-9852) Lower block duration in BufferPoolTest to cut down on overall test runtime

2020-04-10 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081056#comment-17081056 ] Sönke Liebau commented on KAFKA-9852: - [~junrao] as just discussed in the

[jira] [Commented] (KAFKA-9852) Lower block duration in BufferPoolTest to cut down on overall test runtime

2020-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081052#comment-17081052 ] ASF GitHub Bot commented on KAFKA-9852: --- soenkeliebau commented on pull request #8464: KAFKA-9852:

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustedException from doSend() in KafkaProducer

2020-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081045#comment-17081045 ] ASF GitHub Bot commented on KAFKA-3720: --- junrao commented on pull request #8399: KAFKA-3720: Change

[jira] [Commented] (KAFKA-8124) Beginning offset is after the ending offset for topic partition

2020-04-10 Thread Rishabh (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081023#comment-17081023 ] Rishabh commented on KAFKA-8124: +1 > Beginning offset is after the ending offset for topic partition >

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

2020-04-10 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080989#comment-17080989 ] Vinoth Chandar commented on KAFKA-9846: --- Understood, I was always wary of grabbing those maps at

[jira] [Updated] (KAFKA-9642) "BigDecimal(double)" should not be used

2020-04-10 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis updated KAFKA-9642: -- Fix Version/s: 2.6.0 > "BigDecimal(double)" should not be used >

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

2020-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080978#comment-17080978 ] ASF GitHub Bot commented on KAFKA-9846: --- vinothchandar commented on pull request #8462: KAFKA-9846:

[jira] [Assigned] (KAFKA-4668) Mirrormaker should default to auto.offset.reset=earliest

2020-04-10 Thread Jeff Widman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Widman reassigned KAFKA-4668: -- Assignee: Jeff Widman > Mirrormaker should default to auto.offset.reset=earliest >

[jira] [Commented] (KAFKA-9603) Number of open files keeps increasing in Streams application

2020-04-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080887#comment-17080887 ] Guozhang Wang commented on KAFKA-9603: -- Great, thanks! I'd be waiting for you to share the mini

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-04-10 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080875#comment-17080875 ] Guozhang Wang commented on KAFKA-9592: -- I would think so: the current javadoc of abortTxn says

[jira] [Commented] (KAFKA-9832) Extend EOS system tests for EOS-beta

2020-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080856#comment-17080856 ] ASF GitHub Bot commented on KAFKA-9832: --- mjsax commented on pull request #8443: KAFKA-9832: Extend

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

2020-04-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080851#comment-17080851 ] ASF GitHub Bot commented on KAFKA-6145: --- vvcephei commented on pull request #8436: KAFKA-6145:

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: I have a particular blog to explain the whole context at here 

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}There were log segments, which can not be deleted over

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}There were log segments, which can not be deleted over

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}There were log segments, which can not be deleted over

[jira] [Commented] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080668#comment-17080668 ] Jiangtao Liu commented on KAFKA-8270: - Please comment me if you need to have more context. > Kafka

[jira] [Comment Edited] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080665#comment-17080665 ] Jiangtao Liu edited comment on KAFKA-8270 at 4/10/20, 5:58 PM: --- In a short

[jira] [Comment Edited] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080665#comment-17080665 ] Jiangtao Liu edited comment on KAFKA-8270 at 4/10/20, 5:57 PM: --- In a short

[jira] [Commented] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080665#comment-17080665 ] Jiangtao Liu commented on KAFKA-8270: - Anyone if you have or may run into the issue, you can take a

[jira] [Comment Edited] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822636#comment-16822636 ] Jiangtao Liu edited comment on KAFKA-8270 at 4/10/20, 5:53 PM: --- [~Yohan123]

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}There were log segments, which can not be deleted over

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}There were log segments, which can not deleted after over

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Component/s: logging log cleaner > Kafka timestamp-based retention policy is not

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Affects Version/s: 1.1.1 > Kafka timestamp-based retention policy is not working when Kafka

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's timestamp is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue? {quote}We have log retention with 12 hours. there are log segments

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's time is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Summary: Kafka timestamp-based retention policy is not working when Kafka client's time is not

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's timestamp is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: What's the issue and impact? {quote}We have log retention with 12 hours. there are

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's timestamp is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: what's the issue? {quote}we have log retention with 12 hours. there are log segments

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's timestamp is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Description: what's the issue? we have log retention with 12 hours. there are log segments not

[jira] [Created] (KAFKA-9851) Revoking Connect tasks due to connectivity issues should also clear running assignment

2020-04-10 Thread Konstantine Karantasis (Jira)
Konstantine Karantasis created KAFKA-9851: - Summary: Revoking Connect tasks due to connectivity issues should also clear running assignment Key: KAFKA-9851 URL:

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

2020-04-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080636#comment-17080636 ] Sophie Blee-Goldman commented on KAFKA-9846: True, the literal Task.State was introduced for

[jira] [Created] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

2020-04-10 Thread Levani Kokhreidze (Jira)
Levani Kokhreidze created KAFKA-9850: Summary: Move KStream#repartition operator validation during Topology build process Key: KAFKA-9850 URL: https://issues.apache.org/jira/browse/KAFKA-9850

[jira] [Assigned] (KAFKA-9323) Refactor Streams' upgrade system tests

2020-04-10 Thread Nikolay Izhikov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Izhikov reassigned KAFKA-9323: -- Assignee: (was: Nikolay Izhikov) > Refactor Streams' upgrade system tests >

[jira] [Resolved] (KAFKA-6910) Ability to specify a default state store type or factory

2020-04-10 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6910. Resolution: Duplicate > Ability to specify a default state store type or factory >

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

2020-04-10 Thread Vinoth Chandar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080554#comment-17080554 ] Vinoth Chandar commented on KAFKA-9846: --- hi [~ableegoldman], if you were talking about Task.State,

[jira] [Updated] (KAFKA-8270) Kafka timestamp-based retention policy is not working when Kafka client's timestamp is not reliable.

2020-04-10 Thread Jiangtao Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangtao Liu updated KAFKA-8270: Summary: Kafka timestamp-based retention policy is not working when Kafka client's timestamp is

[jira] [Commented] (KAFKA-9744) SchemaProjector fails to handle change of record namespace in Avro schema

2020-04-10 Thread Jurgis Pods (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080426#comment-17080426 ] Jurgis Pods commented on KAFKA-9744: I've updated my bug report to be more clear. In short: Avro does

[jira] [Updated] (KAFKA-9744) SchemaProjector fails to handle change of record namespace in Avro schema

2020-04-10 Thread Jurgis Pods (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jurgis Pods updated KAFKA-9744: --- Description: _Note_: This bug report is for CP 5.3.1 / Kafka 2.3.1, but it most likely affects all

[jira] [Updated] (KAFKA-9744) SchemaProjector fails to handle change of record namespace in Avro schema

2020-04-10 Thread Jurgis Pods (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jurgis Pods updated KAFKA-9744: --- Summary: SchemaProjector fails to handle change of record namespace in Avro schema (was:

[jira] [Updated] (KAFKA-9744) SchemaProjector fails to handle backwards-compatible schema change

2020-04-10 Thread Jurgis Pods (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jurgis Pods updated KAFKA-9744: --- Description: _Note_: This bug report is for CP 5.3.1 / Kafka 2.3.1, but it most likely affects all

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-04-10 Thread Xiang Zhang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080280#comment-17080280 ] Xiang Zhang commented on KAFKA-9592: [~bchen225242]  Thanks. Do we still need a small KIP for this ?

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-04-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080274#comment-17080274 ] Boyang Chen commented on KAFKA-9592: [~iamabug] Yes, I think your understanding is correct. > Safely