Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Hi Jorge, Thanks for the update. I think this is a good plan. I just took a look at the KIP again, and it looks like there’s a revision error in which two methods are proposed for SessionStore, but seem like they should be in ReadOnlySessionStore. Do I read that right? Otherwise, I’m happy

[jira] [Created] (KAFKA-10227) Enforce cleanup policy to only contain compact or delete once

Mickael Maison created KAFKA-10227: -- Summary: Enforce cleanup policy to only contain compact or delete once Key: KAFKA-10227 URL: https://issues.apache.org/jira/browse/KAFKA-10227 Project: Kafka

Jenkins build is back to normal : kafka-2.5-jdk8 #162

See

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Thanks John. > it looks like there’s a revision error in which two methods are proposed for SessionStore, but seem like they should be in ReadOnlySessionStore. Do I read that right? Yes, I've opted to keep the new methods alongside the existing ones. In the case of SessionStore, `findSessions`

Re: Permission to create KIPs

Hi, Thanks for your interest. I have given you wiki edit permissions. Thanks, On Thu, Jul 2, 2020 at 9:05 PM Arvin Zheng wrote: > Hi, > > Could someone please help grant permission to create KIPs to user > arvin.zheng? > > Thanks, > Arvin >

Jenkins build is back to normal : kafka-2.4-jdk8 #231

See

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

(sorry for the spam) Actually `findSessions` are only deprecated on `InMemorySessionStore`, which seems strange as RocksDB and interfaces haven't marked these methods as deprecated. Any hint on how to handle this? Cheers, On Thu, Jul 2, 2020 at 4:57 PM Jorge Esteban Quilcate Otoya <

Permission to create KIPs

Hi, Could someone please help grant permission to create KIPs to user arvin.zheng? Thanks, Arvin

[jira] [Created] (KAFKA-10228) producer: NETWORK_EXCEPTION is thrown instead of a request timeout

Christian Becker created KAFKA-10228: Summary: producer: NETWORK_EXCEPTION is thrown instead of a request timeout Key: KAFKA-10228 URL: https://issues.apache.org/jira/browse/KAFKA-10228 Project:

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

@John: I can see there are some deprecations in there as well. Will update the KIP. Thanks, Jorge On Thu, Jul 2, 2020 at 3:29 PM Jorge Esteban Quilcate Otoya < quilcate.jo...@gmail.com> wrote: > Thanks John. > > > it looks like there’s a revision error in which two methods are proposed > for

[jira] [Created] (KAFKA-10229) Kafka stream dies when earlier shut down node leaves group, no errors logged on client

Raman Gupta created KAFKA-10229: --- Summary: Kafka stream dies when earlier shut down node leaves group, no errors logged on client Key: KAFKA-10229 URL: https://issues.apache.org/jira/browse/KAFKA-10229

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

See Changes: [github] KAFKA-10006: Don't create internal topics when -- [...truncated 3.16 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest >

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Hey Jorge, Thanks for the details. That sounds like a mistake to me on both counts. I don’t think you need to worry about those depreciations. If the interface methods aren’t deprecated, then the methods are not deprecated. We should remove the annotations, but it doesn’t need to be in the

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi Navinder, Thanks for the response. I’m sorry if I’m being dense... You said we are not currently using the config, but I thought we would pass the config through to the client. Can you confirm whether or not the existing config works for your use case? Thanks, John On Sun, Jun 28, 2020,

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

See Changes: [github] KAFKA-10173: Use SmokeTest for upgrade system tests (#8938) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-10173: Use SmokeTest for upgrade system tests (#8938) -- [...truncated 3.16 MB...] org.apache.kafka.streams.internals.WindowStoreFacadeTest >

Build failed in Jenkins: kafka-trunk-jdk11 #1615

See Changes: [github] KAFKA-10006: Don't create internal topics when -- [...truncated 3.19 MB...] org.apache.kafka.streams.TestTopicsTest > testEmptyTopic STARTED

Build failed in Jenkins: kafka-trunk-jdk11 #1616

See Changes: [github] KAFKA-10173: Use SmokeTest for upgrade system tests (#8938) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TestTopicsTest >

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

See Changes: [github] KAFKA-10006: Don't create internal topics when -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-10230) Include min.insync.replicas in MetadataResponse to make Producer smarter in determining unavailable partitions

Arvin Zheng created KAFKA-10230: --- Summary: Include min.insync.replicas in MetadataResponse to make Producer smarter in determining unavailable partitions Key: KAFKA-10230 URL:

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

See Changes: [github] MINOR: Update Netty to 4.1.50.Final (#8972) -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

See Changes: [github] MINOR: Update Netty to 4.1.50.Final (#8972) -- [...truncated 3.17 MB...] org.apache.kafka.streams.scala.TopologyTest >

Build failed in Jenkins: kafka-trunk-jdk11 #1614

See Changes: [github] MINOR: Update Netty to 4.1.50.Final (#8972) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-10226) KStream without SASL information should return error in confluent cloud

Werner Daehn created KAFKA-10226: Summary: KStream without SASL information should return error in confluent cloud Key: KAFKA-10226 URL: https://issues.apache.org/jira/browse/KAFKA-10226 Project:

[jira] [Created] (KAFKA-10225) Increase default zk session timeout for system test

Chia-Ping Tsai created KAFKA-10225: -- Summary: Increase default zk session timeout for system test Key: KAFKA-10225 URL: https://issues.apache.org/jira/browse/KAFKA-10225 Project: Kafka