Permissions for creating KIP

Hi, Please give me permission for creating KIP . You can find link to my profile on confluence here . Kind regards, Levani

[DISCUSS] KIP-485 Make topic optional when using through() operations in DSL

Hello, I would like to start discussion about KIP-485 Make topic optional when using through() operations in DSL Regards, Levani

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Hello, I would like to resurrect discussion around KIP-221. Going through the discussion thread, there’s seems to agreement around usefulness of this feature. Regarding the implementation, as far as I understood, the most optimal solution for me seems the following: 1) Add two method overload

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

discussed in the mailing list, but I kinda got with all the threads that were about this KIP :( Kind regards, Levani > On Jul 1, 2019, at 9:56 AM, Levani Kokhreidze wrote: > > Hello, > > I would like to resurrect discussion around KIP-221. Going through the > discussion thr

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

gs, like replication > factor, retention-time etc, easily, without the need to change the "main > API". > > Just want to give some ideas. Not sure if I like them myself. :) > > > -Matthias > > > > On 7/1/19 1:04 AM, Levani Kokhreidze wrote: >> Actually

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

nce+KStream+with+Connecting+Topic+Creation+and+Repartition+Hint> I’ve also filled “Rejected Alternatives” section. Looking forward to discuss this KIP :) King regards, Levani > On Jul 3, 2019, at 1:08 PM, Levani Kokhreidze wrote: > > Hello Matthias, > > Thanks for the feedback

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

int> Regards, Levani > On Jul 9, 2019, at 11:38 AM, Levani Kokhreidze wrote: > > Hello, > > In order to move this KIP forward, I’ve updated confluence page with the new > proposal > https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+KStream+with+Co

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

int>) so it doesn’t get lost in mailing list :) Would love to hear communities opinions/concerns about this KIP. Regards, Levani > On Jul 12, 2019, at 5:27 PM, Levani Kokhreidze wrote: > > Hello, > > Kind reminder about this KIP: > https://cwiki.apache.org/confluence/

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

eem like one version of the method will auto-create > topics while the other will not. > > Cheers, > Sophie > > On Wed, Jul 17, 2019 at 10:15 AM Levani Kokhreidze > wrote: > >> Hello, >> >> One more bump about KIP-221 ( >> https://cwiki.apache.or

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

ed? I'm not sure how > widely this feature is really used, but seems it should be available for > repartition topics. > > On Wed, Jul 17, 2019 at 11:26 AM Levani Kokhreidze > wrote: > >> Hey Sophie, >> >> In both cases KStream#repartition and KStream#repar

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

> input topic uses a custom partitioning strategy, then the > repartitioned stream also needs to be partitioned with the same > strategy. > > Does that make sense, or did I maybe miss something important? > > Thanks, > -John > > On Wed, Jul 17, 2019 at 2:48 PM Lev

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

r option in Produced. > > Thanks, > -John > > On Wed, Jul 17, 2019 at 3:20 PM Levani Kokhreidze > wrote: >> >> Hey John, >> >> Oh that’s interesting use-case. >> Do I understand this correctly, in your example I would first issue >> repartitio

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

n of fields in the value in conjunction with the key > 2. Something other than the key > 3. We allow users to specify a partitioner on Produced hence in > KStream.to and KStream.through, so it makes sense for API consistency. > > Just my 2 cents. > > Thanks, &g

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

on't think we do this kind of composition elsewhere in Streams at > the moment > > On Fri, Jul 19, 2019 at 1:45 PM Levani Kokhreidze > wrote: > >> Hi Bill, >> >> Thanks a lot for the feedback. >> Yes, that makes sense. I’ve updated KIP with `Reparti

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

o avoid abbreviations. Can > we rename: > > `withNumOfPartitions` -> `withNumberOfPartitions` > > Furthermore, it might be good to add some more `static` methods: > > - Repartitioned.with(Serde, Serde) > - Repartitioned.withNumberOfPartitions(int) > - Repartitioned.streamPa

[VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

Hello, I’d like to initialize voting on KIP-221: https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+KStream+with+Connecting+Topic+Creation+and+Repartition+Hint

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Hello, Thanks all for your feedback. I started voting procedure for this KIP. If there’re any other concerns about this KIP, please let me know. Regards, Levani > On Jul 20, 2019, at 8:39 PM, Levani Kokhreidze wrote: > > Hi Matthias, > > Thanks for the suggestion, make

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

's valuable to keep the number of overload small if possible.) > > Otherwise LGTM. > > > -Matthias > > > On 7/23/19 2:18 PM, Levani Kokhreidze wrote: >> Hello, >> >> Thanks all for your feedback. >> I started voting procedure for this KIP. I

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Hi all, Here’s voting thread for this KIP: https://www.mail-archive.com/dev@kafka.apache.org/msg99680.html <https://www.mail-archive.com/dev@kafka.apache.org/msg99680.html> Regards, Levani > On Jul 24, 2019, at 11:15 PM, Levani Kokhreidze > wrote: > > Hi Matthias, &

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

Hello, Still waiting for feedback on this KIP. Please let me know if you have any concerns and/or questions. Regards, Levani > On Jul 24, 2019, at 8:20 PM, Sophie Blee-Goldman wrote: > > Looks good! Thanks Levani, > > +1 (non-binding) > > Sophie > > On Tue, Jul

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

> On Tue, Jul 30, 2019 at 1:27 PM Bill Bejeck wrote: > >> Thanks for the KIP Levani. >> >> +1 (binding) >> >> -Bill >> >> On Tue, Jul 30, 2019 at 3:37 PM Levani Kokhreidze >> wrote: >> >>> Hello, >>> >>&

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

Sax wrote: > > +1 (binding) > > On 7/31/19 8:36 AM, Guozhang Wang wrote: >> Thanks for the update! +1 (binding). >> >> On Tue, Jul 30, 2019 at 11:42 PM Levani Kokhreidze >> wrote: >> >>> Hello Guozhang, >>> >>> Thanks for the f

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

ou have any concerns. Regards, Levani > On Jul 26, 2019, at 11:25 AM, Levani Kokhreidze > wrote: > > Hi all, > > Here’s voting thread for this KIP: > https://www.mail-archive.com/dev@kafka.apache.org/msg99680.html > <https://www.mail-archive.com/dev@kafka.

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

are busy with the upcoming 2.4 release, and don't have much > spare time at the > moment. It's kind of a difficult time to get attention on things, but feel > free to pick up something else > to work on in the meantime until things have calmed down a bit! > > Cheers,

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

idea of adding `numberOfPartitions` to Grouped rather than > adding a new parameter to groupBy, that does seem more in line with the > current syntax so +1 from me > > On Tue, Nov 5, 2019 at 2:07 PM Levani Kokhreidze > wrote: > >> Hello all, >> >> While

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

>>>> make an explicit call to `repartition()` IMHO -- piggybacking an >>>> enforced repartitioning into `groupByKey()` seems to be "dangerous" >>>> because it might be too subtle and an "optional scaling out" as laid out >>>> above doe

Re: [VOTE] KIP-629: Use racially neutral terms in our codebase

+1 (non-binding) Thank you for this initiative. Levani > On Jun 26, 2020, at 11:53 AM, Mickael Maison wrote: > > +1 (binding) > Thanks for the KIP! > > On Fri, Jun 26, 2020 at 9:51 AM Jorge Esteban Quilcate Otoya > wrote: >> >> +1 (non-binding) >> Thank you Xavier! >> >> On Fri, Jun 26, 20

Re: [VOTE] 2.6.0 RC0

Hi Randall, Not sure if it’s intentional but, documentation for Kafka Streams 2.6.0 also contains “Streams API changes in 2.7.0” https://kafka.apache.org/26/documentation/streams/upgrade-guide Also, there seems to be some format

KAFKA-15571 Review

Hello, We’ve been looking at a https://issues.apache.org/jira/browse/KAFKA-10575 but seems implementation has a bug and user defined `StateRestoreListener#onRestoreSuspended` is not called because DelegatingStateRestoreListener was not updated. Here’s the PR that fixes it: https://github.com/a

Re: KAFKA-15571 Review

found a bug and you are looking at the right place! > > I commented on the PR. > > Best, > Bruno > > On 10/10/23 3:02 PM, Levani Kokhreidze wrote: >> Hello, >> We’ve been looking at a https://issues.apache.org/jira/browse/KAFKA-10575 >&g

[DISCUSS] 3.5.2 Release

Hello, KAFKA-15571 [1] was merged and backported to the 3.5 and 3.6 branches. Bug fixes the feature that was added in 3.5. Considering the feature doesn't work as expected without a fix, I would like to know if it's reasonable to start the 3.5.2 release. Of course, releasing such a massive proj

Re: [DISCUSS] 3.5.2 Release

> For 3.5.2, I think there are sufficient pending (including some CVE fixes) >> to start a bug fix release. We just need a volunteer for the release >> manager. >> >> -- >> Divij Vaidya >> >> >> >> On Thu, Oct 12, 2023 at 9:57 AM Levani Kok

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

+DSL+with+Connecting+Topic+Creation+and+Repartition+Hint>) Regards, Levani > On Aug 1, 2019, at 9:55 AM, Levani Kokhreidze wrote: > > Thank you all! > > The vote has been open for ~8 days. KIP has three binding votes (Bill, > Guozhang, Matthias) and one non-binding (Sophie)

Re: [VOTE] KIP-221: Enhance KStream with Connecting Topic Creation and Repartition Hint

anual >> repartitioning before transform()) however this pattern should be >> subsumed by repartition(). >> >> Reducing the surface area of our API (instead of just enlarging it) >> might be good. >> >> Thoughts? >> >> >> -Matthias >&

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Congrats Bruno, well deserved! On Wed, 2 Nov 2022, 11:11 Jorge Esteban Quilcate Otoya, < quilcate.jo...@gmail.com> wrote: > Congratulations, Bruno!! > > On Wed, 2 Nov 2022, 09:06 Mickael Maison, > wrote: > > > Congratulations Bruno! > > > > On Wed, Nov 2, 2022 at 8:33 AM Matthew Benedict de Detr

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

gt;>>>> user opt-in to trigger it. Just setting an optional parameter might be >>>>> too subtle to trigger such a heavy "side effect". >>>>> >>>>> While I agree about "usability" in general, I would prefer a more >>>>> conservative

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

t;>> >>>> If anything, this discussion really supports to me the value in just >>>> sticking with `repartition()` for now, and deferring >>>> `groupBy[Key](partitions)` to the future. >>>> >>>>> Users should not have to choose betwe

Issues with triggering the build

Hello, Seems like there’re issues with triggering Jenkins builds. Latest commits for my PR doesn’t trigger any of the builds. Any ideas how to fix the issue? Here’s the example PR: https://github.com/apache/kafka/pull/7170 - Levani

Re: Issues with triggering the build

rk. > > Best, > Bruno > > On Tue, Jan 14, 2020 at 9:01 AM Levani Kokhreidze > wrote: >> >> Hello, >> >> Seems like there’re issues with triggering Jenkins builds. Latest commits >> for my PR doesn’t trigger any of the builds. >> Any ideas h

Re: Subject: [VOTE] 2.4.1 RC0

+1 non-binding. - Built from source - Ran unit tests. All passed. - Quickstart passed. Looking forward upgrading to 2.4.1 Regards, Levani On Mon, 9 Mar 2020, 17:11 Sean Glover, wrote: > +1 (non-binding). I built from source and ran the unit test suite > successfully. > > Thanks for running t

Re: [DISCUSS] Apache Kafka 3.2.0 release

Hi Bruno, I assume we will be able to merge changes tomorrow as well? Thanks, Levani > On 15. Mar 2022, at 16:11, Bruno Cadonna wrote: > > Hi all, > > A quick reminder that feature freeze for Apache 3.2.0 is tomorrow. Please > make sure to get your features merged into trunk. > > I will cut

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

Hi, Sorry, maybe I am jumping the gun here, but if by any chance this KIP becomes dormant, I'd be interested in picking it up. Levani > On 23. Apr 2022, at 02:43, Matthias J. Sax wrote: > > Ivan, > > are you still interested in this KIP? I think it would be a good addition. > > > -Matthias

Re: [DISCUSS] KIP-759: Unneeded repartition canceling

ree to pick it up. > > > -Matthias > > On 4/26/22 3:58 AM, Levani Kokhreidze wrote: >> Hi, >> Sorry, maybe I am jumping the gun here, but if by any chance this KIP >> becomes dormant, I'd be interested in picking it up. >> Levani >>> On 23. A

[DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hello all, I’d like to start discussion on KIP-708 [1] that aims to introduce rack aware standby task distribution in Kafka Streams. In addition to changes mentioned in the KIP, I’d like to get some ideas on additional change I have in mind. Assuming KIP moves forward, I was wondering if it mak

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

on to summarizing what rack awareness > looks like in other distributed systems, to help us put this design in > context. > > Thanks! > John > > > On Tue, Jan 26, 2021, at 16:46, Levani Kokhreidze wrote: >> Hello all, >> >> I’d like to start discuss

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

re to what extent clients can learn the > relevant broker metadata, so this stretch might not be > currently feasible, but as long as we design the > TaskAssignor for extensibility, we can do something like > this in the future. > > Thanks again for this proposal, I hope the above is

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

ace (point 2) to a separate KIP. I do think a pluggable > assignor would be extremely valuable, but it might be nice to cut the scope > of KIP-708 if just a config will suffice. > > What do you think? > Thanks, > John > > > On Mon, Feb 1, 2021, at 06:07, Levani Kokhr

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

nstances > * one copy in each of zone a, b, and c > * two copies in one cluster and one in the other cluster > > For example, we might have 0_0 assigned to: > * Node 1 (cluster 1, zone a) > * Node 5 (cluster 2, zone b) > * Node 3 (cluster 1, zone c) > > Is that what you wer

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hello all, I’ve updated KIP-708 [1] to reflect the latest discussion outcomes. I’m looking forward to your feedback. Regards, Levani [1] - https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awarness+for+Kafka+Streams > On 2. Feb 2021, at 22:03, Levani Kokhreidze wr

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

es it? > > 7. Could you also say some words about how this KIP affects the current > HighAvailabilityTaskAssignor? > > > Best, > Bruno > > On 09.02.21 15:54, Levani Kokhreidze wrote: >> Hello all, >> I’ve updated KIP-708 [1] to reflect the latest disc

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

ignor react on different numbers and different orderings > of the tags in standby.replicas.awareness across Streams clients? > > Best, > Bruno > > > On 22.02.21 11:46, Levani Kokhreidze wrote: >> Hi Bruno, >> Thanks for the feedback. Please check my answers below: >&

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

nfluence/display/KAFKA/KIP-441%3A+Smooth+Scaling+Out+for+Kafka+Streams#KIP441:SmoothScalingOutforKafkaStreams-AssignmentAlgorithm > > <https://cwiki.apache.org/confluence/display/KAFKA/KIP-441%3A+Smooth+Scaling+Out+for+Kafka+Streams#KIP441:SmoothScalingOutforKafkaStreams-AssignmentAlgorit

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

re how the tag approach is different than appending > multiple tags together, e.g. how is cluster=foo, zone=bar different than > rack=foo-bar? > > Ryanne > > On Sat, Feb 27, 2021, 5:00 PM Levani Kokhreidze <mailto:levani.co...@gmail.com>> > wrote: >

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

Hi Bruno, Thanks a lot for the feedback. I’ve updated KIP [1] based on suggestions. Regards, Levani [1] - https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awarness+for+Kafka+Streams > On 1. Mar 2021, at 22:55, Bruno Cadonna wrote: > > clientTagPrefix

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

nce/display/KAFKA/KIP-708:+Rack+awarness+for+Kafka+Streams> > On 4. Mar 2021, at 10:36, Levani Kokhreidze wrote: > > Hi Bruno, > > Thanks a lot for the feedback. > I’ve updated KIP [1] based on suggestions. > > Regards, > Levani > > [1] - > https://cwiki.a

Re: [DISCUSS] KIP-708: Rack aware Kafka Streams with pluggable StandbyTask assignor

licas. I think > there is no need to refer to actual code. > > After this changes, I am +1 on starting the vote thread. > > Best, > Bruno > > On 08.03.21 17:32, Levani Kokhreidze wrote: >> Hello all, >> Bumping this thread in case there’s any other feedback around KI

[VOTE] KIP-708: Rack awareness for Kafka Streams

Hello all, I’d like to start the voting on KIP-708 [1] Best, Levani [1] - https://cwiki.apache.org/confluence/display/KAFKA/KIP-708%3A+Rack+awareness+for+Kafka+Streams

Re: [VOTE] KIP-708: Rack awareness for Kafka Streams

> Guozhang > > > > > On Thu, Mar 11, 2021 at 8:29 AM John Roesler wrote: > >> Thanks for the KIP! >> >> I'm +1 (binding) >> >> -John >> >> On Wed, 2021-03-10 at 13:13 +0200, Levani Kokhreidze wrote: >>> Hello all, &g

Re: [VOTE] KIP-708: Rack awareness for Kafka Streams

Hello all, Bumping this thread as we are one binding vote short accepting this KIP. Please let me know if you have any extra concerns and/or suggestions. Regards, Levani > On 12. Mar 2021, at 13:14, Levani Kokhreidze wrote: > > Hi Guozhang, > > Thanks for the feedback. I think

Re: [VOTE] KIP-708: Rack awareness for Kafka Streams

Hi Sophie and Bruno, Thanks for the questions and suggestions. Not sure if it's best to discuss this in the DISCUSSION thread, but I will write it here first, and if it needs more discussion, we can move to the DISCUSSION thread. Actually, in the implementation, I have a version field in the Cli

Re: [VOTE] KIP-708: Rack awareness for Kafka Streams

rd with the current KIP, I'm +1 (binding) -- > thanks for the proposal Levani! > > Cheers, > Sophie > > > On Wed, Mar 17, 2021 at 7:54 AM Levani Kokhreidze > wrote: > >> Hi Sophie and Bruno, >> >> Thanks for the questions and suggestions. >>

Re: [VOTE] KIP-708: Rack awareness for Kafka Streams

here, and if users do hit limits on bytes, probably they'd consider giving > some shorter names anyways :) > > Guozhang > > On Wed, Mar 17, 2021 at 11:25 AM Levani Kokhreidze > wrote: > >> Hi Sophie, >> >> No worries! And thanks for taking a look. >

Re: [DISCUSS] Apache Kafka 3.0.0 release plan with new updated dates

Hi Konstantine, FYI, I don’t think we will be able to have KIP-708 ready on time. Feel free to remove it from the release plan. Best, Levani > On 1. Jul 2021, at 01:27, Konstantine Karantasis > wrote: > > Hi all, > > Today we have reached the Feature Freeze milestone for Apache Kafka 3.0. >

[jira] [Created] (KAFKA-8413) Add possibility to do repartitioning on KStream

Levani Kokhreidze created KAFKA-8413: Summary: Add possibility to do repartitioning on KStream Key: KAFKA-8413 URL: https://issues.apache.org/jira/browse/KAFKA-8413 Project: Kafka Issue

[jira] [Created] (KAFKA-8611) Make topic optional when using through() operations in DSL

Levani Kokhreidze created KAFKA-8611: Summary: Make topic optional when using through() operations in DSL Key: KAFKA-8611 URL: https://issues.apache.org/jira/browse/KAFKA-8611 Project: Kafka

[jira] [Created] (KAFKA-8727) Control over standby tasks host assignment

Levani Kokhreidze created KAFKA-8727: Summary: Control over standby tasks host assignment Key: KAFKA-8727 URL: https://issues.apache.org/jira/browse/KAFKA-8727 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-8727) Control over standby tasks host assignment

[ https://issues.apache.org/jira/browse/KAFKA-8727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze resolved KAFKA-8727. -- Resolution: Duplicate  Duplicate of KAFKA-6718 > Control over standby tasks h

[jira] [Created] (KAFKA-8871) Allow timestamp manipulation in ValueTransformerWithKey

Levani Kokhreidze created KAFKA-8871: Summary: Allow timestamp manipulation in ValueTransformerWithKey Key: KAFKA-8871 URL: https://issues.apache.org/jira/browse/KAFKA-8871 Project: Kafka

[jira] [Created] (KAFKA-9031) Add possibility to reset Kafka streams application state to specific point in time

Levani Kokhreidze created KAFKA-9031: Summary: Add possibility to reset Kafka streams application state to specific point in time Key: KAFKA-9031 URL: https://issues.apache.org/jira/browse/KAFKA-9031

[jira] [Created] (KAFKA-10375) Restore consumer fails with SSL handshake fail exception

Levani Kokhreidze created KAFKA-10375: - Summary: Restore consumer fails with SSL handshake fail exception Key: KAFKA-10375 URL: https://issues.apache.org/jira/browse/KAFKA-10375 Project: Kafka

[jira] [Created] (KAFKA-10454) Kafka Streams Stuck in infinite REBALANCING loop when stream <> table join partitions don't match

Levani Kokhreidze created KAFKA-10454: - Summary: Kafka Streams Stuck in infinite REBALANCING loop when stream <> table join partitions don't match Key: KAFKA-10454 URL: https://issues.apache.org/

[jira] [Created] (KAFKA-15571) StateRestoreListener#onRestoreSuspended is never called because wrapper DelegatingStateRestoreListener doesn't implement onRestoreSuspended

Levani Kokhreidze created KAFKA-15571: - Summary: StateRestoreListener#onRestoreSuspended is never called because wrapper DelegatingStateRestoreListener doesn't implement onRestoreSuspended Key: KAFKA-

[jira] [Resolved] (KAFKA-15659) Flaky test RestoreIntegrationTest.shouldInvokeUserDefinedGlobalStateRestoreListener

[ https://issues.apache.org/jira/browse/KAFKA-15659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levani Kokhreidze resolved KAFKA-15659. --- Resolution: Fixed > Flaky t

[jira] [Created] (KAFKA-9828) Add partition to TestRecord in streams test-utils

Levani Kokhreidze created KAFKA-9828: Summary: Add partition to TestRecord in streams test-utils Key: KAFKA-9828 URL: https://issues.apache.org/jira/browse/KAFKA-9828 Project: Kafka

[jira] [Created] (KAFKA-9850) Move KStream#repartition operator validation during Topology build process

Levani Kokhreidze created KAFKA-9850: Summary: Move KStream#repartition operator validation during Topology build process Key: KAFKA-9850 URL: https://issues.apache.org/jira/browse/KAFKA-9850

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

Levani Kokhreidze created KAFKA-9859: Summary: kafka-streams-application-reset tool doesn't take into account topics generated by KTable foreign key join operation Key: KAFKA-9859 URL:

[jira] [Reopened] (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:all-tabpanel ] Levani Kokhreidze reopened KAFKA-9859: -- > kafka-streams-application-reset tool doesn't take into account topics > g

[jira] [Created] (KAFKA-10003) Deprecate KStream#through in favor of KStream#repartition

Levani Kokhreidze created KAFKA-10003: - Summary: Deprecate KStream#through in favor of KStream#repartition Key: KAFKA-10003 URL: https://issues.apache.org/jira/browse/KAFKA-10003 Project: Kafka

[jira] [Resolved] (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:all-tabpanel ] Levani Kokhreidze resolved KAFKA-9859. -- Fix Version/s: 2.6.0 Resolution: Fixed fixed with PR [https://github.com/apache

[jira] [Created] (KAFKA-9197) Consider introducing numberOfPartitions configuration field to Grouped configuration class

Levani Kokhreidze created KAFKA-9197: Summary: Consider introducing numberOfPartitions configuration field to Grouped configuration class Key: KAFKA-9197 URL: https://issues.apache.org/jira/browse/KAFKA-9197

[jira] [Created] (KAFKA-9240) Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker

Levani Kokhreidze created KAFKA-9240: Summary: Flaky test kafka.admin.ReassignPartitionsClusterTest.shouldMoveSinglePartitionWithinBroker Key: KAFKA-9240 URL: https://issues.apache.org/jira/browse/KAFKA-9240

[jira] [Created] (KAFKA-9342) Consider making all Kafka Streams DSL configuration classes immutable

Levani Kokhreidze created KAFKA-9342: Summary: Consider making all Kafka Streams DSL configuration classes immutable Key: KAFKA-9342 URL: https://issues.apache.org/jira/browse/KAFKA-9342 Project

[jira] [Created] (KAFKA-9638) Do not trigger REBALANCING when specific exceptions occur in Kafka Streams

Levani Kokhreidze created KAFKA-9638: Summary: Do not trigger REBALANCING when specific exceptions occur in Kafka Streams Key: KAFKA-9638 URL: https://issues.apache.org/jira/browse/KAFKA-9638

[jira] [Created] (KAFKA-10686) Pluggable standby tasks assignor for Kafka Streams

Levani Kokhreidze created KAFKA-10686: - Summary: Pluggable standby tasks assignor for Kafka Streams Key: KAFKA-10686 URL: https://issues.apache.org/jira/browse/KAFKA-10686 Project: Kafka

[jira] [Created] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

Levani Kokhreidze created KAFKA-10772: - Summary: java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0) Key: KAFKA-10772