[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&focusedCommentId=17410827#comment-17410827 ] Adam Bellemare commented on KAFKA-13261: Hi [~xnix] - Thank you for the test cod

[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&focusedCommentId=17408303#comment-17408303 ] Adam Bellemare edited comment on KAFKA-13261 at 9/1/21, 6:05 PM: -

[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&focusedCommentId=17408303#comment-17408303 ] Adam Bellemare commented on KAFKA-13261: Hi [~xnix]. We'll need some more inform

[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&focusedCommentId=17287100#comment-17287100 ] Adam Bellemare commented on KAFKA-12323: [~mjsax]Sure, I can pick it up - though

[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&focusedCommentId=17283909#comment-17283909 ] Adam Bellemare commented on KAFKA-12323: Alright, I think I found source of the

[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&focusedCommentId=17283409#comment-17283409 ] Adam Bellemare commented on KAFKA-12323: Hi [~ableegoldman] I am trying to rep

[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 eve

[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&focusedCommentId=17152701#comment-17152701 ] Adam Bellemare commented on KAFKA-9168: --- This would be incredibly useful for improv

[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&focusedCommentId=17120564#comment-17120564 ] Adam Bellemare commented on KAFKA-10049: Thanks [~amicngh] for finding and repor

[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&focusedCommentId=17120563#comment-17120563 ] Adam Bellemare commented on KAFKA-10049: PR is up. > KTable-KTable Foreign 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&focusedCommentId=17119834#comment-17119834 ] Adam Bellemare commented on KAFKA-10049: Can do. I'll take care of it. Thanks fo

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

[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 Ex

[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&focusedCommentId=17119197#comment-17119197 ] Adam Bellemare commented on KAFKA-10049: Found the bug. The SubscriptionWrapperS

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

[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&focusedCommentId=17118937#comment-17118937 ] Adam Bellemare commented on KAFKA-10049: [~amicngh] Okay, I was able to reproduc

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

[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 Jo

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

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

[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&focusedCommentId=17061804#comment-17061804 ] Adam Bellemare commented on KAFKA-9500: --- [~vvcephei] Hey John - I ran across this

[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: https://issues.apache.org/jira/br

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868544#comment-16868544 ] Adam Bellemare commented on KAFKA-7500: --- [~ryannedolan] - Thanks for driving this f

[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&focusedCommentId=16816656#comment-16816656 ] Adam Bellemare edited comment on KAFKA-3705 at 4/12/19 9:05 PM: ---

[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&focusedCommentId=16816656#comment-16816656 ] Adam Bellemare commented on KAFKA-3705: --- The PR is now in a draft state - there are

[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&focusedCommentId=16692424#comment-16692424 ] Adam Bellemare commented on KAFKA-4212: --- We have some business requirements where w

[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 Pr

[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&focusedCommentId=16516314#comment-16516314 ] Adam Bellemare commented on KAFKA-4628: --- For those who are interested, I have creat

[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&focusedCommentId=16506025#comment-16506025 ] Adam Bellemare commented on KAFKA-4628: --- Someone added me - thank you! I will be wo

[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&focusedCommentId=16505943#comment-16505943 ] Adam Bellemare commented on KAFKA-4628: --- [~yuzhih...@gmail.com] - I am trying to st

[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&focusedCommentId=16503374#comment-16503374 ] Adam Bellemare commented on KAFKA-4628: --- [~yuzhih...@gmail.com] Yes, I will take a

[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&focusedCommentId=16492617#comment-16492617 ] Adam Bellemare commented on KAFKA-4628: --- Thanks Guozhang, I appreciate you taking th

[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&focusedCommentId=16492200#comment-16492200 ] Adam Bellemare commented on KAFKA-3705: --- I too am interested, as my org, like many o

[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&focusedCommentId=16489168#comment-16489168 ] Adam Bellemare commented on KAFKA-4628: --- [~guozhang] - Do you happen to know an esti

[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&focusedCommentId=16487005#comment-16487005 ] Adam Bellemare commented on KAFKA-4628: --- [~guozhang] Any updates on this? I have en