Re: [DISCUSS] KIP-405: Kafka Tiered Storage

Hi, i wan to unsubscribe from this list. Can i do it? Please :) Thank u! Regards!! El sáb., 11 jul. 2020 a las 22:06, Adam Bellemare () escribió: > My 2 cents - > > I agree with Colin. I think that it's important that the metadata not grow > unbounded without being delegated to external

Re: [DISCUSS] KIP-405: Kafka Tiered Storage

My 2 cents - I agree with Colin. I think that it's important that the metadata not grow unbounded without being delegated to external storage. Indefinite long-term storage of entity data in Kafka can result in extremely large datasets where the vast majority of data is stored in the external

Build failed in Jenkins: kafka-trunk-jdk8 #4710

See Changes: [github] KAFKA-10247: Correctly reset state when task is corrupted (#8994) -- [...truncated 6.35 MB...]

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hey, no problem, Sagar! Yes, I think this is a good time for the voting thread, since all the concerns have been addressed in the discussion, and it’s been a while. You can find the rules on the main KIP page, and examples of vote messages in the mailing list. Thanks, John On Sat, Jul 11,

Build failed in Jenkins: kafka-trunk-jdk14 #285

See Changes: [github] KAFKA-10262: Ensure that creating task directory is thread safe (#9010) [github] KAFKA-10247: Correctly reset state when task is corrupted (#8994)

Jenkins build is back to normal : kafka-2.6-jdk8 #78

See

Re: [DISCUSS] KIP-450: Sliding Windows

Leah, thanks for your update. However, it does not completely answer my question. In our current window implementations, we emit a window result update record (ie, early/partial result) for each input record. When an out-of-order record arrives, we just update to corresponding old window and

[jira] [Resolved] (KAFKA-10247) Streams may attempt to process after closing a task

[ https://issues.apache.org/jira/browse/KAFKA-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10247. - Fix Version/s: 2.6.0 Resolution: Fixed > Streams may attempt to process after

[jira] [Resolved] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10262. - Fix Version/s: 2.6.0 Resolution: Fixed > StateDirectory is not thread-safe >

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Thanks John, Sorry I’m new to this process.  does it mean I start a voting email? Pardon my ignorance. Sagar. On Sat, 11 Jul 2020 at 8:06 PM, John Roesler wrote: > Hi Sagar, > > Thanks for the update. As far as I’m concerned, I’m ready to vote now. > > Thanks, > John > > On Mon, Jul 6,

Re: [DISCUSS] KIP-614: Add Prefix Scan support for State Stores

Hi Sagar, Thanks for the update. As far as I’m concerned, I’m ready to vote now. Thanks, John On Mon, Jul 6, 2020, at 12:58, Sagar wrote: > Hi John, > > Thanks, I have updated the KIP. > > Thanks! > Sagar. > > On Mon, Jul 6, 2020 at 12:00 AM John Roesler wrote: > > > Hi Sagar, > > > >

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Thanks, Yuriy, IIRC, I added VoidSerde because there are times when the key or value is always null, but since ‘null’ has no type in Java, we had used the ByteArraySerde or some other proxy. This is confusing, because then the type is ‘byte[]’ although we intended it to always be null. It also