[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410827#comment-17410827 ] Adam Bellemare commented on KAFKA-13261: Hi [~xnix] - Thank you for the test code to reproduce

[jira] [Comment Edited] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408303#comment-17408303 ] Adam Bellemare edited comment on KAFKA-13261 at 9/1/21, 6:05 PM: - Hi

[jira] [Commented] (KAFKA-13261) KTable to KTable foreign key join loose events when using several partitions

[ https://issues.apache.org/jira/browse/KAFKA-13261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408303#comment-17408303 ] Adam Bellemare commented on KAFKA-13261: Hi [~xnix]. We'll need some more information: Have you

[jira] [Commented] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287100#comment-17287100 ] Adam Bellemare commented on KAFKA-12323: [~mjsax]Sure, I can pick it up - though I won't likely

[jira] [Updated] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Bellemare updated KAFKA-12323: --- Priority: Major (was: Blocker) > Record timestamps not populated in event >

[jira] [Commented] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283909#comment-17283909 ] Adam Bellemare commented on KAFKA-12323: Alright, I think I found source of the 0 timestamp

[jira] [Updated] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Bellemare updated KAFKA-12323: --- Attachment: PunctuateTimestampZeroTest.java > Record timestamps not populated in event >

[jira] [Commented] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17283409#comment-17283409 ] Adam Bellemare commented on KAFKA-12323: Hi [~ableegoldman] I am trying to reproduce it all on

[jira] [Updated] (KAFKA-12323) Record timestamps not populated in event

[ https://issues.apache.org/jira/browse/KAFKA-12323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adam Bellemare updated KAFKA-12323: --- Description: Upgraded a kafka streams application from 2.6.0 to 2.7.0. Noticed that the

[jira] [Created] (KAFKA-12323) Record timestamps not populated in event

Adam Bellemare created KAFKA-12323: -- Summary: Record timestamps not populated in event Key: KAFKA-12323 URL: https://issues.apache.org/jira/browse/KAFKA-12323 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152701#comment-17152701 ] Adam Bellemare commented on KAFKA-9168: --- This would be incredibly useful for improving the

[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=17120564#comment-17120564 ] Adam Bellemare commented on KAFKA-10049: Thanks [~amicngh] for finding and reporting this bug!

[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=17120563#comment-17120563 ] Adam Bellemare commented on KAFKA-10049: PR is up. > KTable-KTable Foreign Key join throwing

[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=17119834#comment-17119834 ] Adam Bellemare commented on KAFKA-10049: Can do. I'll take care of it. Thanks for your help

[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=17119818#comment-17119818 ] Adam Bellemare commented on KAFKA-10049: Hey [~vvcephei]  - thanks for the PR! I appreciate you

[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 ] Adam Bellemare updated KAFKA-10049: --- Attachment: 10049-bellemare.patch > KTable-KTable Foreign Key join throwing Serialization

[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=17119197#comment-17119197 ] Adam Bellemare commented on KAFKA-10049: Found the bug. The SubscriptionWrapperSerde wraps a Key

[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=17119014#comment-17119014 ] Adam Bellemare commented on KAFKA-10049: [~vvcephei] Hey John, didn't you fix an issue around

[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=17118937#comment-17118937 ] Adam Bellemare commented on KAFKA-10049: [~amicngh] Okay, I was able to reproduce it. I'll look

[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=17117976#comment-17117976 ] Adam Bellemare commented on KAFKA-10049: Is this us? I think this is their serializer

[jira] [Resolved] (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:all-tabpanel ] Adam Bellemare resolved KAFKA-9732. --- Resolution: Not A Problem Issue was with reporter's usage of the API. > Kafka Foreign-Key

[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=17065224#comment-17065224 ] Adam Bellemare commented on KAFKA-9732: --- [~vvcephei] Gah! Thank you! I was tearing my hair out

[jira] [Comment Edited] (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=17061921#comment-17061921 ] Adam Bellemare edited comment on KAFKA-9732 at 3/18/20, 5:14 PM: -

[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=17061921#comment-17061921 ] Adam Bellemare commented on KAFKA-9732: --- [~vvcephei] Hey John Not sure if this is a known-issue

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

[ https://issues.apache.org/jira/browse/KAFKA-9500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061804#comment-17061804 ] Adam Bellemare commented on KAFKA-9500: --- [~vvcephei] Hey John - I ran across this while trying to

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

Adam Bellemare created KAFKA-9732: - Summary: Kafka Foreign-Key Joiner has unexpected default value used when a table is created via a stream+groupByKey+reduce Key: KAFKA-9732 URL:

[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=16868544#comment-16868544 ] Adam Bellemare commented on KAFKA-7500: --- [~ryannedolan] - Thanks for driving this forward, it looks

[jira] [Comment Edited] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816656#comment-16816656 ] Adam Bellemare edited comment on KAFKA-3705 at 4/12/19 9:05 PM: The PR is

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816656#comment-16816656 ] Adam Bellemare commented on KAFKA-3705: --- The PR is now in a draft state - there are a few issues

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692424#comment-16692424 ] Adam Bellemare commented on KAFKA-4212: --- We have some business requirements where we need to store

[jira] [Created] (KAFKA-7552) StatefulProcessorNode tries to connect state store to processor before it is added

Adam Bellemare created KAFKA-7552: - Summary: StatefulProcessorNode tries to connect state store to processor before it is added Key: KAFKA-7552 URL: https://issues.apache.org/jira/browse/KAFKA-7552

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516314#comment-16516314 ] Adam Bellemare commented on KAFKA-4628: --- For those who are interested, I have created the KIP and

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506025#comment-16506025 ] Adam Bellemare commented on KAFKA-4628: --- Someone added me - thank you! I will be working on the KIP

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505943#comment-16505943 ] Adam Bellemare commented on KAFKA-4628: --- [~yuzhih...@gmail.com] - I am trying to start a KIP, but

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16503374#comment-16503374 ] Adam Bellemare commented on KAFKA-4628: --- [~yuzhih...@gmail.com] Yes, I will take a look at doing

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492617#comment-16492617 ] Adam Bellemare commented on KAFKA-4628: --- Thanks Guozhang, I appreciate you taking the time to reply.

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16492200#comment-16492200 ] Adam Bellemare commented on KAFKA-3705: --- I too am interested, as my org, like many others, have been

[jira] [Commented] (KAFKA-4628) Support KTable/GlobalKTable Joins

[ https://issues.apache.org/jira/browse/KAFKA-4628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16487005#comment-16487005 ] Adam Bellemare commented on KAFKA-4628: --- [~guozhang] Any updates on this? I have encountered