[jira] [Commented] (KAFKA-10049) KTable-KTable Foreign Key join throwing Serialization Exception

[ https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119771#comment-17119771 ] John Roesler commented on KAFKA-10049: -- Woah, thanks for digging into that, [~abellemare] ! That's

[jira] [Commented] (KAFKA-4493) Connections to Kafka brokers should be validated

[ https://issues.apache.org/jira/browse/KAFKA-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118860#comment-17118860 ] John Roesler commented on KAFKA-4493: - Hi [~enether] , what's the status on this issue? It has just

[jira] [Commented] (KAFKA-7748) Add wall clock TimeDefinition for suppression of intermediate events

[ https://issues.apache.org/jira/browse/KAFKA-7748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118858#comment-17118858 ] John Roesler commented on KAFKA-7748: - Hi [~pdebuitlear] , It seems like [~jonathanpdx] was unable

[jira] [Created] (KAFKA-10058) Create Windowing Operations overview documentation

John Roesler created KAFKA-10058: Summary: Create Windowing Operations overview documentation Key: KAFKA-10058 URL: https://issues.apache.org/jira/browse/KAFKA-10058 Project: Kafka Issue

[jira] [Commented] (KAFKA-9986) Checkpointing API for State Stores

[ https://issues.apache.org/jira/browse/KAFKA-9986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118850#comment-17118850 ] John Roesler commented on KAFKA-9986: - Hi [~nizhikov] , Thanks for getting involved in this! It's

[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: Affects Version/s: 2.6.0 > Promote Standby tasks to active tasks without closing them >

[jira] [Commented] (KAFKA-10049) KTable-KTable Foreign Key join throwing Serialization Exception

[ https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117922#comment-17117922 ] John Roesler commented on KAFKA-10049: -- I've marked this as a 2.6 blocker. It's not immediately

[jira] [Updated] (KAFKA-10049) KTable-KTable Foreign Key join throwing Serialization Exception

[ https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10049: - Priority: Blocker (was: Major) > KTable-KTable Foreign Key join throwing Serialization

[jira] [Updated] (KAFKA-10049) KTable-KTable Foreign Key join throwing Serialization Exception

[ https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10049: - Affects Version/s: 2.6.0 > KTable-KTable Foreign Key join throwing Serialization Exception >

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117819#comment-17117819 ] John Roesler commented on KAFKA-10017: -- I've just marked this as a blocker for 2.6.0. It's been

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10017: - Priority: Blocker (was: Major) > Flaky Test

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10017: - Affects Version/s: 2.6.0 > Flaky Test

[jira] [Created] (KAFKA-10046) Deprecated PartitionGrouper config is ignored

John Roesler created KAFKA-10046: Summary: Deprecated PartitionGrouper config is ignored Key: KAFKA-10046 URL: https://issues.apache.org/jira/browse/KAFKA-10046 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10017: Assignee: Matthias J. Sax (was: John Roesler) > Flaky Test

[jira] [Assigned] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-10017: Assignee: John Roesler > Flaky Test

[jira] [Commented] (KAFKA-8159) Built-in serdes for signed numbers do not obey lexicographical ordering

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111694#comment-17111694 ] John Roesler commented on KAFKA-8159: - Hi [~ableegoldman] , Thanks for pointing this out in the

[jira] [Updated] (KAFKA-9992) EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13

[ https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9992: Fix Version/s: 2.4.2 > EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13 >

[jira] [Commented] (KAFKA-9992) EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13

[ https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17111433#comment-17111433 ] John Roesler commented on KAFKA-9992: - No problem, [~akatona] ! Thanks again for the contribution.

[jira] [Updated] (KAFKA-9992) EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13

[ https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9992: Fix Version/s: 2.5.1 > EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13 >

[jira] [Updated] (KAFKA-9992) EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13

[ https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9992: Fix Version/s: 2.6.0 > EmbeddedKafkaCluster.deleteTopicAndWait not working with kafka_2.13 >

[jira] [Assigned] (KAFKA-9989) StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task

[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9989: --- Assignee: Boyang Chen > StreamsUpgradeTest.test_metadata_upgrade could not guarantee all

[jira] [Resolved] (KAFKA-9994) Catch TaskMigrated exception in task corruption code path

[ https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9994. - Resolution: Fixed > Catch TaskMigrated exception in task corruption code path >

[jira] [Assigned] (KAFKA-9994) Catch TaskMigrated exception in task corruption code path

[ https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9994: --- Assignee: Boyang Chen > Catch TaskMigrated exception in task corruption code path >

[jira] [Resolved] (KAFKA-10008) Symbol not found when running Kafka Streams with RocksDB dependency on MacOS 10.13.6

[ https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10008. -- Resolution: Won't Fix Following the other comments, we've decided just to document it. >

[jira] [Commented] (KAFKA-9993) Think about inheritance in the protocol generation framework

[ https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108795#comment-17108795 ] John Roesler commented on KAFKA-9993: - Thanks for the context, Boyang! > Think about inheritance in

[jira] [Commented] (KAFKA-9993) Think about inheritance in the protocol generation framework

[ https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107487#comment-17107487 ] John Roesler commented on KAFKA-9993: - Thanks for the idea, Boyang. Can you clarify whether the

[jira] [Commented] (KAFKA-9992) EmbeddedKafkaCluster not working with kafka_2.13

[ https://issues.apache.org/jira/browse/KAFKA-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107394#comment-17107394 ] John Roesler commented on KAFKA-9992: - Hello Andras, Just to make sure I understand, is this just a

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104991#comment-17104991 ] John Roesler commented on KAFKA-9972: - Oh, and I would also be in favor of at least encapsulating the

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104990#comment-17104990 ] John Roesler commented on KAFKA-9972: - Thanks, all. To be clear, I also prefer Sophie’s suggestion to

[jira] [Commented] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104567#comment-17104567 ] John Roesler commented on KAFKA-9798: - Great, thanks! > Flaky test: >

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104536#comment-17104536 ] John Roesler commented on KAFKA-9972: - Thanks for the clarification. The reason I didn’t choose to do

[jira] [Commented] (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:comment-tabpanel=17103420#comment-17103420 ] John Roesler commented on KAFKA-7224: - Hi Maatari, Yeah, it probably seems beside the point because

[jira] [Commented] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103406#comment-17103406 ] John Roesler commented on KAFKA-9798: - Funny you should ask my opinion, since I was just saying to

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103400#comment-17103400 ] John Roesler commented on KAFKA-9972: - Hi Sophie, You hinted at a general solution, but I’m not sure

[jira] [Commented] (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:comment-tabpanel=17097684#comment-17097684 ] John Roesler commented on KAFKA-7224: - Hi all, Thanks for the good points all around. Just to close

[jira] [Commented] (KAFKA-7275) Prototype lock-free metrics

[ https://issues.apache.org/jira/browse/KAFKA-7275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096738#comment-17096738 ] John Roesler commented on KAFKA-7275: - For at least one example of a higher performance, but

[jira] [Updated] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9925: Fix Version/s: 2.5.1 2.4.2 2.6.0 > Non-key KTable Joining

[jira] [Resolved] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9925. - Resolution: Fixed > Non-key KTable Joining may result in duplicate schema name in confluence >

[jira] [Commented] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17095934#comment-17095934 ] John Roesler commented on KAFKA-9925: - Just saw this conversation. Thanks for the idea, [~guozhang] .

[jira] [Updated] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

[ https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9875: Fix Version/s: 2.6.0 > Flaky Test >

[jira] [Resolved] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

[ https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9875. - Resolution: Fixed https://github.com/apache/kafka/pull/8578 > Flaky Test >

[jira] [Assigned] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

[ https://issues.apache.org/jira/browse/KAFKA-9875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9875: --- Assignee: John Roesler > Flaky Test >

[jira] [Commented] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094729#comment-17094729 ] John Roesler commented on KAFKA-9925: - Ok, I've opened [https://github.com/apache/kafka/pull/8574] .

[jira] [Assigned] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9925: --- Assignee: John Roesler > Non-key KTable Joining may result in duplicate schema name in

[jira] [Commented] (KAFKA-9925) Non-key KTable Joining may result in duplicate schema name in confluence schema registry

[ https://issues.apache.org/jira/browse/KAFKA-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094604#comment-17094604 ] John Roesler commented on KAFKA-9925: - Ah, right you are. So sorry I overlooked that part of the bug

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089090#comment-17089090 ] John Roesler commented on KAFKA-8924: - Thanks for the comment, [~cadonna] , I agree that it's not as

[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=17088201#comment-17088201 ] John Roesler commented on KAFKA-9224: - Thanks [~mjsax] , This is a really good point. Actually, we

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088093#comment-17088093 ] John Roesler edited comment on KAFKA-8924 at 4/20/20, 10:14 PM: Hey

[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=17088126#comment-17088126 ] John Roesler commented on KAFKA-9224: - Thanks for the points, all. I think my objection is partly

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088093#comment-17088093 ] John Roesler commented on KAFKA-8924: - Hey [~atais] , it's been quite a while since the last activity

[jira] [Comment Edited] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088091#comment-17088091 ] John Roesler edited comment on KAFKA-8924 at 4/20/20, 9:20 PM: --- I just had

[jira] [Commented] (KAFKA-8924) Default grace period (-1) of TimeWindows causes suppress to emit events after 24h

[ https://issues.apache.org/jira/browse/KAFKA-8924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088091#comment-17088091 ] John Roesler commented on KAFKA-8924: - I just had another conversation with someone else who got bit

[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=17086088#comment-17086088 ] John Roesler commented on KAFKA-9224: - Thanks [~guozhang] , just for clarity, yes, that's the same

[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=17085270#comment-17085270 ] John Roesler edited comment on KAFKA-9224 at 4/16/20, 9:32 PM: --- Thanks,

[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=17085270#comment-17085270 ] John Roesler commented on KAFKA-9224: - Thanks, all, I've re-read this issue, and also read

[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=17085121#comment-17085121 ] John Roesler edited comment on KAFKA-9224 at 4/16/20, 5:51 PM: --- Hi

[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=17085121#comment-17085121 ] John Roesler commented on KAFKA-9224: - Hi [~bchen225242] , this ticket has just come to my attention

[jira] [Commented] (KAFKA-9859) kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation

[ https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082616#comment-17082616 ] John Roesler commented on KAFKA-9859: - Yes, the FK join KIP added two new suffixes: #

[jira] [Assigned] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9798: --- Assignee: Guozhang Wang > Flaky test: >

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

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079987#comment-17079987 ] John Roesler commented on KAFKA-9846: - Thanks for the report [~ableegoldman] . I'd offer one

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

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9846: Fix Version/s: 2.6.0 > Race condition can lead to severe lag underestimate for active tasks >

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077482#comment-17077482 ] John Roesler commented on KAFKA-9831: - Linking possibly related issue. > Failing test: >

[jira] [Created] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

John Roesler created KAFKA-9831: --- Summary: Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta] Key: KAFKA-9831 URL: https://issues.apache.org/jira/browse/KAFKA-9831

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076615#comment-17076615 ] John Roesler commented on KAFKA-9770: - Thanks, [~mjsax] ! > Caching State Store does not Close

[jira] [Updated] (KAFKA-8396) Clean up Transformer API

[ https://issues.apache.org/jira/browse/KAFKA-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8396: Description: Currently, KStream operators transformValues and flatTransformValues disable context

[jira] [Assigned] (KAFKA-9812) Integration tests hang and timeout the entire PR build on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9812: --- Assignee: John Roesler (was: Boyang Chen) > Integration tests hang and timeout the entire

[jira] [Commented] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073222#comment-17073222 ] John Roesler commented on KAFKA-9770: - I can't cherry-pick to the 2.5 branch until the 2.5.0 release

[jira] [Updated] (KAFKA-9770) Caching State Store does not Close Underlying State Store When Exception is Thrown During Flushing

[ https://issues.apache.org/jira/browse/KAFKA-9770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9770: Fix Version/s: 2.6.0 > Caching State Store does not Close Underlying State Store When Exception is

[jira] [Created] (KAFKA-9791) Streams should log the effective RocksDB configuration when opening a database

John Roesler created KAFKA-9791: --- Summary: Streams should log the effective RocksDB configuration when opening a database Key: KAFKA-9791 URL: https://issues.apache.org/jira/browse/KAFKA-9791 Project:

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071938#comment-17071938 ] John Roesler commented on KAFKA-9783: - I've just run it 90 times in a row, and it never failed

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071462#comment-17071462 ] John Roesler commented on KAFKA-9783: - [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/5518/]

[jira] [Resolved] (KAFKA-9742) StandbyTaskEOSIntegrationTest broken

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

[jira] [Commented] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064992#comment-17064992 ] John Roesler commented on KAFKA-9732: - Oh, also FYI, you'll be interested in

[jira] [Commented] (KAFKA-9732) Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce

[ https://issues.apache.org/jira/browse/KAFKA-9732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064989#comment-17064989 ] John Roesler commented on KAFKA-9732: - Hey [~abellemare] , I think the mapValues is where you're

[jira] [Assigned] (KAFKA-9742) StandbyTaskEOSIntegrationTest broken

[ https://issues.apache.org/jira/browse/KAFKA-9742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9742: --- Assignee: John Roesler (was: Boyang Chen) > StandbyTaskEOSIntegrationTest broken >

[jira] [Created] (KAFKA-9742) Flaky test StandbyTaskEOSIntegrationTest

John Roesler created KAFKA-9742: --- Summary: Flaky test StandbyTaskEOSIntegrationTest Key: KAFKA-9742 URL: https://issues.apache.org/jira/browse/KAFKA-9742 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063613#comment-17063613 ] John Roesler commented on KAFKA-9701: - Hey [~bchen225242] , I think I've reproduced this issue in a

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9701: Attachment: cluster.log > Consumer could catch InconsistentGroupProtocolException during rebalance

[jira] [Resolved] (KAFKA-9734) Streams IllegalStateException in trunk during rebalance

[ https://issues.apache.org/jira/browse/KAFKA-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9734. - Resolution: Fixed > Streams IllegalStateException in trunk during rebalance >

[jira] [Created] (KAFKA-9734) Streams IllegalStateException in trunk during rebalance

John Roesler created KAFKA-9734: --- Summary: Streams IllegalStateException in trunk during rebalance Key: KAFKA-9734 URL: https://issues.apache.org/jira/browse/KAFKA-9734 Project: Kafka Issue

[jira] [Resolved] (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 resolved KAFKA-9636. - Resolution: Not A Bug Closing this ticket as "not a bug" because the test failure turned out to

[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=17062223#comment-17062223 ] John Roesler commented on KAFKA-9636: - NP, and thanks again for your assistance and very clear and

[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=17060302#comment-17060302 ] John Roesler commented on KAFKA-9636: - Thanks, [~psnively] ! That's a good idea to add a Scala shim

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059081#comment-17059081 ] John Roesler commented on KAFKA-9568: - I think the idea is that the member is still logically the

[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=17058990#comment-17058990 ] John Roesler commented on KAFKA-9636: - Aha! You gave me a clue. The serde in your code doesn't do

[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=17058813#comment-17058813 ] John Roesler commented on KAFKA-9636: - Hi [~psnively] ,   I'm sorry to hear that; I certainly wish

[jira] [Commented] (KAFKA-7869) Refactor RocksDBConfigSetter API to separate DBOptions and CFOptions

[ https://issues.apache.org/jira/browse/KAFKA-7869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058269#comment-17058269 ] John Roesler commented on KAFKA-7869: - Hey [~dongjin] , The last comments on the PR seem sort of

[jira] [Assigned] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8893: --- Assignee: John Roesler > Flaky ResetIntegrationTest. >

[jira] [Assigned] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8893: --- Assignee: (was: John Roesler) > Flaky ResetIntegrationTest. >

[jira] [Assigned] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8893: --- Assignee: (was: John Roesler) > Flaky ResetIntegrationTest. >

[jira] [Assigned] (KAFKA-8893) Flaky ResetIntegrationTest. testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-8893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8893: --- Assignee: John Roesler > Flaky ResetIntegrationTest. >

[jira] [Updated] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[ https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9676: Issue Type: Test (was: Task) > Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[jira] [Updated] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[ https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9676: Issue Type: Task (was: Test) > Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[jira] [Assigned] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[ https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9676: --- Assignee: (was: John Roesler) > Add test coverage for new ActiveTaskCreator and

[jira] [Assigned] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[ https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9676: --- Assignee: John Roesler > Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

[jira] [Updated] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9675: Priority: Blocker (was: Major) > RocksDB metrics reported always at zero >

[jira] [Updated] (KAFKA-9675) RocksDB metrics reported always at zero

[ https://issues.apache.org/jira/browse/KAFKA-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9675: Fix Version/s: 2.4.1 2.5.0 > RocksDB metrics reported always at zero >

[jira] [Updated] (KAFKA-8403) Make suppression results queriable

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

[jira] [Updated] (KAFKA-8403) Make suppression results queriable

[ https://issues.apache.org/jira/browse/KAFKA-8403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8403: Summary: Make suppression results queriable (was: Suppress needs a Materialized variant) > Make

[jira] [Commented] (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:comment-tabpanel=17054270#comment-17054270 ] John Roesler commented on KAFKA-7224: - I didn't realized I'd left this ticket in progress. I intended

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