[jira] [Assigned] (KAFKA-7224) KIP-328: Add spill-to-disk for Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7224: --- Assignee: (was: John Roesler) > KIP-328: Add spill-to-disk for Suppression >

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17052269#comment-17052269 ] John Roesler commented on KAFKA-9636: - Hey [~psnively] , No problem! Thanks for refining the test

[jira] [Assigned] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9636: --- Assignee: John Roesler > Simple join of two KTables fails >

[jira] [Updated] (KAFKA-7778) Add KTable.suppress to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7778: Fix Version/s: 2.3.0 > Add KTable.suppress to Scala API > > >

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050392#comment-17050392 ] John Roesler commented on KAFKA-9636: - Hi [~psnively] , Incidentally, the 2.4.1 release candidate is

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050367#comment-17050367 ] John Roesler commented on KAFKA-9636: - Hey [~psnively] , I can't claim to fully understand the data

[jira] [Commented] (KAFKA-9636) Simple join of two KTables fails

[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049811#comment-17049811 ] John Roesler commented on KAFKA-9636: - Hi Paul, I was hoping to look at this today, but didn’t get a

[jira] [Updated] (KAFKA-4835) Avoid repartitioning when key change doesn't change partitions

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-4835: Description: >From

[jira] [Updated] (KAFKA-4835) Avoid repartitioning when key change doesn't change partitions

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-4835: Summary: Avoid repartitioning when key change doesn't change partitions (was: Allow users control

[jira] [Commented] (KAFKA-4835) Allow users control over repartitioning

[ https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049315#comment-17049315 ] John Roesler commented on KAFKA-4835: - Hey [~lkokhreidze] ,   This ticket is listed in KIP-221, but

[jira] [Updated] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9533: Fix Version/s: (was: 2.4.1) (was: 2.3.2) (was:

[jira] [Resolved] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-7932. - Resolution: Duplicate Subsumed by https://issues.apache.org/jira/browse/KAFKA-9274 > Streams

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7932: Fix Version/s: (was: 2.5.0) > Streams needs to handle new Producer exceptions >

[jira] [Commented] (KAFKA-5041) Kafka TestKit library

[ https://issues.apache.org/jira/browse/KAFKA-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046820#comment-17046820 ] John Roesler commented on KAFKA-5041: - Hi all, you may also wish to be aware of this recent thread:

[jira] [Commented] (KAFKA-9611) KGroupedTable.aggregate(...) emits incorrect values

[ https://issues.apache.org/jira/browse/KAFKA-9611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046798#comment-17046798 ] John Roesler commented on KAFKA-9611: - Hi [~neilgreen] , It seems like classifying this as a bug is

[jira] [Resolved] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8147. - Resolution: Fixed Merged as

[jira] [Updated] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8147: Fix Version/s: 2.6.0 > Add changelog topic configuration to KTable suppress >

[jira] [Reopened] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-9533: - > ValueTransform forwards `null` values > - > >

[jira] [Commented] (KAFKA-9533) ValueTransform forwards `null` values

[ https://issues.apache.org/jira/browse/KAFKA-9533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044602#comment-17044602 ] John Roesler commented on KAFKA-9533: - Hi [~mviamari] , Since merging this fix into trunk, we've

[jira] [Issue Comment Deleted] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9274: Comment: was deleted (was: Thanks for the PRs, [~mjsax]! I think Github is having some issues

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17040177#comment-17040177 ] John Roesler commented on KAFKA-9274: - Thanks for the PRs, [~mjsax]! I think Github is having some

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038518#comment-17038518 ] John Roesler commented on KAFKA-6793: - Amending my previous comment, after looking over the history

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037912#comment-17037912 ] John Roesler commented on KAFKA-9552: - Regarding “fail fast”, it does seem like potentially the best

[jira] [Commented] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037691#comment-17037691 ] John Roesler commented on KAFKA-9552: - Thanks, Matthias. What you say sounds right. I’m wondering if

[jira] [Created] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

John Roesler created KAFKA-9562: --- Summary: Streams not making progress under heavy failures with EOS enabled on 2.5 branch Key: KAFKA-9562 URL: https://issues.apache.org/jira/browse/KAFKA-9562 Project:

[jira] [Resolved] (KAFKA-9557) Thread-level "process" metrics are computed incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-9557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9557. - Fix Version/s: 2.6.0 Resolution: Fixed > Thread-level "process" metrics are computed

[jira] [Created] (KAFKA-9557) Thread-level "process" metrics are computed incorrectly

John Roesler created KAFKA-9557: --- Summary: Thread-level "process" metrics are computed incorrectly Key: KAFKA-9557 URL: https://issues.apache.org/jira/browse/KAFKA-9557 Project: Kafka Issue

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035500#comment-17035500 ] John Roesler commented on KAFKA-9517: - Hi [~psnively], Just another quick update: now all the

[jira] [Resolved] (KAFKA-9500) Foreign-Key Join creates an invalid topology

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9500. - Resolution: Fixed > Foreign-Key Join creates an invalid topology >

[jira] [Resolved] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9503. - Resolution: Fixed > TopologyTestDriver processes intermediate results in the wrong order >

[jira] [Resolved] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9390. - Resolution: Fixed > Non-key joining of KTable not compatible with confluent avro serdes >

[jira] [Commented] (KAFKA-6793) Unnecessary warning log message

[ https://issues.apache.org/jira/browse/KAFKA-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034616#comment-17034616 ] John Roesler commented on KAFKA-6793: - It seems like we could fix this simply by not passing invalid

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033985#comment-17033985 ] John Roesler commented on KAFKA-9517: - Quick update, I've merged this fix to trunk, 2.5, and 2.4.

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033960#comment-17033960 ] John Roesler commented on KAFKA-9517: - Hi Paul, Ah, those failures shouldn't affect your testing.

[jira] [Commented] (KAFKA-8307) Kafka Streams should provide some mechanism to determine topology equality and compatibility

[ https://issues.apache.org/jira/browse/KAFKA-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032806#comment-17032806 ] John Roesler commented on KAFKA-8307: - Thanks for the comment, [~guozhang]. It closely matches what

[jira] [Commented] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032805#comment-17032805 ] John Roesler commented on KAFKA-9518: - Sure thing. I've linked them. > NullPointerException on

[jira] [Commented] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032788#comment-17032788 ] John Roesler commented on KAFKA-9525: - Agreed. If "trigger a rebalance" is the desired operation,

[jira] [Commented] (KAFKA-9524) Default window retention does not consider grace period

[ https://issues.apache.org/jira/browse/KAFKA-9524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032714#comment-17032714 ] John Roesler commented on KAFKA-9524: - Thanks for the report, [~mikebin]! FWIW, the workaround is to

[jira] [Commented] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

[ https://issues.apache.org/jira/browse/KAFKA-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032632#comment-17032632 ] John Roesler commented on KAFKA-9248: - Hey [~mjsax], I just saw this ticket. I think it's the same as

[jira] [Assigned] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9517: --- Assignee: John Roesler > KTable Joins Without Materialized Argument Yield Results That

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032630#comment-17032630 ] John Roesler commented on KAFKA-9517: - Hi [~psnively], thanks for your kind words. Actually, the

[jira] [Commented] (KAFKA-8810) Add mechanism to detect topology mismatch between streams instances

[ https://issues.apache.org/jira/browse/KAFKA-8810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032509#comment-17032509 ] John Roesler commented on KAFKA-8810: - This issue has been lurking for a while, and has been reported

[jira] [Commented] (KAFKA-8307) Kafka Streams should provide some mechanism to determine topology equality and compatibility

[ https://issues.apache.org/jira/browse/KAFKA-8307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032511#comment-17032511 ] John Roesler commented on KAFKA-8307: - This issue has been lurking for a while, and has been reported

[jira] [Commented] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032508#comment-17032508 ] John Roesler commented on KAFKA-9518: - This issue has been lurking for a while, and has been reported

[jira] [Commented] (KAFKA-7669) Stream topology definition is not robust to the ordering changes

[ https://issues.apache.org/jira/browse/KAFKA-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032512#comment-17032512 ] John Roesler commented on KAFKA-7669: - This issue has been lurking for a while, and has been reported

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032005#comment-17032005 ] John Roesler commented on KAFKA-9517: - Aha! I think I've found it: {noformat}

[jira] [Commented] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031988#comment-17031988 ] John Roesler commented on KAFKA-9518: - I've just gotten a seemingly similar report for 1.1.1 .

[jira] [Updated] (KAFKA-9518) NullPointerException on out-of-order topologies

[ https://issues.apache.org/jira/browse/KAFKA-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9518: Affects Version/s: 1.1.1 > NullPointerException on out-of-order topologies >

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031953#comment-17031953 ] John Roesler commented on KAFKA-9517: - Thanks for the update, [~psnively]. I've been trying to

[jira] [Comment Edited] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031953#comment-17031953 ] John Roesler edited comment on KAFKA-9517 at 2/6/20 9:25 PM: - Thanks for the

[jira] [Updated] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9390: Fix Version/s: 2.4.1 > Non-key joining of KTable not compatible with confluent avro serdes >

[jira] [Updated] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9390: Fix Version/s: 2.5.0 > Non-key joining of KTable not compatible with confluent avro serdes >

[jira] [Updated] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9390: Priority: Blocker (was: Major) > Non-key joining of KTable not compatible with confluent avro

[jira] [Commented] (KAFKA-9517) KTable Joins Without Materialized Argument Yield Results That Further Joins NPE On

[ https://issues.apache.org/jira/browse/KAFKA-9517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031893#comment-17031893 ] John Roesler commented on KAFKA-9517: - Hey [~psnively], Thanks for the report. I think this is the

[jira] [Assigned] (KAFKA-9390) Non-key joining of KTable not compatible with confluent avro serdes

[ https://issues.apache.org/jira/browse/KAFKA-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9390: --- Assignee: John Roesler > Non-key joining of KTable not compatible with confluent avro

[jira] [Updated] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9501: Fix Version/s: (was: 2.5.0) > Promote Standby tasks to active tasks without closing them >

[jira] [Updated] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9501: Priority: Critical (was: Blocker) > Promote Standby tasks to active tasks without closing them >

[jira] [Updated] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9501: Fix Version/s: 2.5.0 > Promote Standby tasks to active tasks without closing them >

[jira] [Updated] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9501: Priority: Blocker (was: Critical) > Promote Standby tasks to active tasks without closing them >

[jira] [Updated] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

[ https://issues.apache.org/jira/browse/KAFKA-9503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9503: Description: TopologyTestDriver has the feature that it processes each input synchronously,

[jira] [Created] (KAFKA-9503) TopologyTestDriver processes intermediate results in the wrong order

John Roesler created KAFKA-9503: --- Summary: TopologyTestDriver processes intermediate results in the wrong order Key: KAFKA-9503 URL: https://issues.apache.org/jira/browse/KAFKA-9503 Project: Kafka

[jira] [Created] (KAFKA-9500) Foreign-Key Join creates an invalid topology

John Roesler created KAFKA-9500: --- Summary: Foreign-Key Join creates an invalid topology Key: KAFKA-9500 URL: https://issues.apache.org/jira/browse/KAFKA-9500 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018501#comment-17018501 ] John Roesler commented on KAFKA-9450: - This reminds me of an idea I proposed a while back, and

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017671#comment-17017671 ] John Roesler commented on KAFKA-9259: - Ah, yes, it’s the same issue. Bummer we didn’t notice before

[jira] [Resolved] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-6144. - Resolution: Fixed > Allow serving interactive queries from in-sync Standbys >

[jira] [Updated] (KAFKA-6144) Allow serving interactive queries from in-sync Standbys

[ https://issues.apache.org/jira/browse/KAFKA-6144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-6144: Fix Version/s: 2.5.0 > Allow serving interactive queries from in-sync Standbys >

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Parent: (was: KAFKA-6144) Issue Type: Improvement (was: Sub-task) > Tighten up lag

[jira] [Resolved] (KAFKA-9431) Expose API in KafkaStreams to fetch all local offset lags

[ https://issues.apache.org/jira/browse/KAFKA-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9431. - Resolution: Fixed > Expose API in KafkaStreams to fetch all local offset lags >

[jira] [Assigned] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9430: --- Assignee: (was: John Roesler) > Tighten up lag estimates when source topic optimization

[jira] [Assigned] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9430: --- Assignee: John Roesler (was: Vinoth Chandar) > Tighten up lag estimates when source topic

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Description: Right now, we use _endOffsets_ of the source topic for the computation. For

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Priority: Blocker (was: Major) > Tighten up lag estimates when source topic optimization is on >

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Affects Version/s: 2.5.0 > Tighten up lag estimates when source topic optimization is on >

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Fix Version/s: (was: 2.5.0) > Tighten up lag estimates when source topic optimization is on >

[jira] [Updated] (KAFKA-9430) Tighten up lag estimates when source topic optimization is on

[ https://issues.apache.org/jira/browse/KAFKA-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9430: Description: Right now, we use _endOffsets_ of the source topic for the computation. Since the

[jira] [Resolved] (KAFKA-9429) Allow ability to control whether stale reads out of state stores are desirable

[ https://issues.apache.org/jira/browse/KAFKA-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9429. - Resolution: Fixed > Allow ability to control whether stale reads out of state stores are

[jira] [Resolved] (KAFKA-9428) Expose standby information in KafkaStreams via queryMetadataForKey API

[ https://issues.apache.org/jira/browse/KAFKA-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9428. - Resolution: Fixed > Expose standby information in KafkaStreams via queryMetadataForKey API >

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016489#comment-17016489 ] John Roesler commented on KAFKA-9259: - Yep! That sounds right. > suppress() for windowed-Serdes does

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17013373#comment-17013373 ] John Roesler commented on KAFKA-8770: - Hey! Thanks for the effort on this. I looked over your draft.

[jira] [Commented] (KAFKA-9342) Consider making all Kafka Streams DSL configuration classes immutable

[ https://issues.apache.org/jira/browse/KAFKA-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17012064#comment-17012064 ] John Roesler commented on KAFKA-9342: - Hey [~lkokhreidze], As promised, I added the proposal to the

[jira] [Resolved] (KAFKA-8868) Consider auto-generating Streams binary protocol messages

[ https://issues.apache.org/jira/browse/KAFKA-8868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8868. - Resolution: Fixed > Consider auto-generating Streams binary protocol messages >

[jira] [Assigned] (KAFKA-5948) EosIntegrationTest fails with TopicAlreadyMarkedForDeletionException

[ https://issues.apache.org/jira/browse/KAFKA-5948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-5948: --- Assignee: (was: Damian Guy) > EosIntegrationTest fails with

[jira] [Commented] (KAFKA-8770) Either switch to or add an option for emit-on-change

[ https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008118#comment-17008118 ] John Roesler commented on KAFKA-8770: - Thanks for the comment, Richard. Caching is an important

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008115#comment-17008115 ] John Roesler commented on KAFKA-9259: - That’s correct, Omkar, and in the dsl code (like

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17008094#comment-17008094 ] John Roesler commented on KAFKA-8037: - Hey, all. If I understood, the proposal is something like:

[jira] [Commented] (KAFKA-9342) Consider making all Kafka Streams DSL configuration classes immutable

[ https://issues.apache.org/jira/browse/KAFKA-9342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006488#comment-17006488 ] John Roesler commented on KAFKA-9342: - Thanks for this. I also find it pretty annoying. I have

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17006183#comment-17006183 ] John Roesler commented on KAFKA-9259: - There are serdes for the Windowed types, but they need an

[jira] [Commented] (KAFKA-7640) Kafka stream interactive query not returning data when state is backed by rocksdb

[ https://issues.apache.org/jira/browse/KAFKA-7640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005831#comment-17005831 ] John Roesler commented on KAFKA-7640: - Hi [~hiteshbachanna], Sorry for the delay, I'm away on

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004592#comment-17004592 ] John Roesler commented on KAFKA-7663: - Thanks for taking a look, Guozhang. I have concerns about the

[jira] [Commented] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003806#comment-17003806 ] John Roesler commented on KAFKA-9331: - I could get behind this because the current behavior seems not

[jira] [Updated] (KAFKA-9331) Add option to terminate application when StreamThread(s) die

[ https://issues.apache.org/jira/browse/KAFKA-9331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9331: Labels: needs-kip (was: ) > Add option to terminate application when StreamThread(s) die >

[jira] [Commented] (KAFKA-4149) java.lang.NoSuchMethodError when running streams tests

[ https://issues.apache.org/jira/browse/KAFKA-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17003327#comment-17003327 ] John Roesler commented on KAFKA-4149: - Hi @sdhalex, Have you observed this happening? Ismael said we

[jira] [Updated] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9011: Fix Version/s: 2.4.1 > Add KStream#flatTransform and KStream#flatTransformValues to Scala API >

[jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001799#comment-17001799 ] John Roesler commented on KAFKA-9011: - Hey [~akokachev], I cherry-picked them to 2.4, but on 2.3 we

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001795#comment-17001795 ] John Roesler commented on KAFKA-8147: - Note for the future. [~mjduijn] is unable to finish up this

[jira] [Assigned] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8147: --- Assignee: (was: Maarten) > Add changelog topic configuration to KTable suppress >

[jira] [Resolved] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9310. - Resolution: Fixed > StreamThread may die from recoverable UnknownProducerId exception >

[jira] [Updated] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9310: Fix Version/s: 2.4.1 > StreamThread may die from recoverable UnknownProducerId exception >

[jira] [Assigned] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9310: --- Assignee: John Roesler > StreamThread may die from recoverable UnknownProducerId exception

[jira] [Created] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

John Roesler created KAFKA-9310: --- Summary: StreamThread may die from recoverable UnknownProducerId exception Key: KAFKA-9310 URL: https://issues.apache.org/jira/browse/KAFKA-9310 Project: Kafka

<    3   4   5   6   7   8   9   10   11   12   >