GauthamM-official commented on pull request #11816:
URL: https://github.com/apache/kafka/pull/11816#issuecomment-1055242474
Hi @mumrah Could this be merged?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499437#comment-17499437
]
Pratim Chaudhuri commented on KAFKA-13658:
--
[~showuon] - I have never contribu
[
https://issues.apache.org/jira/browse/KAFKA-10857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498863#comment-17498863
]
Guram Savinov edited comment on KAFKA-10857 at 3/1/22, 10:43 AM:
-
tombentley commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r816647178
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499456#comment-17499456
]
Bruno Cadonna commented on KAFKA-13658:
---
[~pratimsc] Have a look at https://kafka.
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499456#comment-17499456
]
Bruno Cadonna edited comment on KAFKA-13658 at 3/1/22, 11:07 AM:
-
tombentley commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r816664173
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,46 @@
protected SourceConnectorConte
Elkhan Eminov created KAFKA-13702:
-
Summary: Connect RestClient overrides response status code on
request failure
Key: KAFKA-13702
URL: https://issues.apache.org/jira/browse/KAFKA-13702
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499511#comment-17499511
]
Leander Ede commented on KAFKA-5072:
Hi, would like to see this implemented as well.
showuon commented on pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#issuecomment-1055416727
@hachikuji , I finally got time to investigate it. Short answer to your
question: Yes, you're right!
> From what I can tell, there might still be a race between the time
justinrlee commented on pull request #11811:
URL: https://github.com/apache/kafka/pull/11811#issuecomment-1055418346
I'm really not sure, have never done this before. When I do the build
locally, I get a bunch of what look like completely test failures. I'm not
sure how my PR would cause
showuon commented on pull request #11681:
URL: https://github.com/apache/kafka/pull/11681#issuecomment-1055418619
Also updated the PR title and description. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499530#comment-17499530
]
Bruno Cadonna commented on KAFKA-13638:
---
[~Lejon] Do you have any news regarding t
cadonna commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-1055442027
@lkokhreidze I will try to have a look this week. I would also like to get
this PR merged as soon as possible. Since @showuon has already approved it. If
I will not manage to
lkokhreidze commented on pull request #10851:
URL: https://github.com/apache/kafka/pull/10851#issuecomment-1055489018
Thanks @cadonna, appreciate it.
@showuon please also note that next PR, the protocol change, is also ready
to be reviewed. https://github.com/apache/kafka/pull/10802
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499589#comment-17499589
]
Pratim Chaudhuri commented on KAFKA-13658:
--
[~cadonna] [~showuon]
Looks like
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499590#comment-17499590
]
Bruno Cadonna commented on KAFKA-13658:
---
[~pratimsc] Thank you for checking!
I wi
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-13658:
--
Fix Version/s: 3.2.0
> Upgrade vulnerable dependencies jan 2022
>
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499594#comment-17499594
]
Bruno Cadonna commented on KAFKA-13658:
---
[~mimaison] Is this relevant for the 3.0.
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499590#comment-17499590
]
Bruno Cadonna edited comment on KAFKA-13658 at 3/1/22, 2:56 PM:
--
bbejeck commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-1055538021
Test failures are unrelated
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the sp
bbejeck merged pull request #7082:
URL: https://github.com/apache/kafka/pull/7082
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...
bbejeck commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-1055547363
Thanks, @bfncs for the contribution and your patience!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
Comonut closed pull request #10516:
URL: https://github.com/apache/kafka/pull/10516
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr.
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499610#comment-17499610
]
Mickael Maison commented on KAFKA-13658:
[~cadonna] Thanks for heads up. Yeah we
mimaison commented on pull request #11803:
URL: https://github.com/apache/kafka/pull/11803#issuecomment-1055584957
Hi @ecararus, thanks for the PR.
As this is changing public APIs, this type of change requires following the
KIP process:
https://cwiki.apache.org/confluence/display/KA
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499618#comment-17499618
]
Bruno Cadonna commented on KAFKA-13658:
---
[~mimaison] Are you going to do that or s
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499627#comment-17499627
]
Mickael Maison commented on KAFKA-13658:
As far as I can tell we're only missing
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8659:
---
Fix Version/s: 3.2.0
> SetSchemaMetadata SMT fails on records with null value and schema
> --
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-8659.
Resolution: Fixed
Resovled via https://github.com/apache/kafka/pull/7082
> SetSchemaMetadata SMT f
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8659:
--
Assignee: (was: Bill Bejeck)
> SetSchemaMetadata SMT fails on records with null value and
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8659:
--
Assignee: Bill Bejeck
> SetSchemaMetadata SMT fails on records with null value and schema
> --
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-8659:
---
Fix Version/s: 3.0.1
3.1.1
> SetSchemaMetadata SMT fails on records with null valu
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-8659:
--
Assignee: Marc Löhe
> SetSchemaMetadata SMT fails on records with null value and schema
>
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13658:
---
Fix Version/s: 3.0.1
3.1.1
> Upgrade vulnerable dependencies jan 2022
> -
[
https://issues.apache.org/jira/browse/KAFKA-13579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13579:
---
Fix Version/s: 3.0.1
3.1.1
> Upgrade vulnerable dependencies
>
[
https://issues.apache.org/jira/browse/KAFKA-13658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499662#comment-17499662
]
Mickael Maison commented on KAFKA-13658:
Back ported to 3.0 and 3.1. Can we reso
[
https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13159:
---
Fix Version/s: (was: 3.0.1)
> Enable system tests for transactions in KRaft mode
> -
[
https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499666#comment-17499666
]
Mickael Maison commented on KAFKA-13159:
No reply so I'm moving it out of 3.0.1
[
https://issues.apache.org/jira/browse/KAFKA-13142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499667#comment-17499667
]
Mickael Maison commented on KAFKA-13142:
No reply so I'm moving this out of 3.0.
[
https://issues.apache.org/jira/browse/KAFKA-13142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-13142:
---
Fix Version/s: (was: 3.0.1)
> KRaft brokers do not validate dynamic configs before forwa
mimaison commented on pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#issuecomment-1055678947
@ijuma Can you take another look? I'm just waiting on this before getting
started on 3.0.1.
--
This is an automated message from the Apache Git Service.
To respond to the me
guozhangwang commented on pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#issuecomment-1055679613
@ableegoldman I took another look at the latest commit, and LGTM.
The jenkins build timeout seems consistent though, and maybe related; after
your investigation on i
guozhangwang commented on a change in pull request #11823:
URL: https://github.com/apache/kafka/pull/11823#discussion_r816990985
##
File path: streams/src/test/resources/log4j.properties
##
@@ -18,9 +18,18 @@ log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appende
bbejeck commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-1055684585
@bfncs I've also added you as a contributor on Jira so you'll be able to
assign tickets to yourself in the future
--
This is an automated message from the Apache Git Service.
T
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r816996953
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -205,25 +208,31 @@
/** metric.reporters */
public
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r816997743
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -202,25 +208,31 @@
/** metric.reporters */
public
ijuma commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r816997743
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -202,25 +208,31 @@
/** metric.reporters */
public
ijuma commented on pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#issuecomment-1055690966
@mimaison @showuon I left a couple more minor comments that should
hopefully be easy to address.
--
This is an automated message from the Apache Git Service.
To respond to the
bfncs commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-1055715698
Thanks for reviewing, merging and adding me to Jira, @bbejeck. 💐
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
wcarlson5 commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r816411304
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/NamedTopologyTest.java
##
@@ -149,7 +149,7 @@ public void
shouldThrow
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499683#comment-17499683
]
Guozhang Wang commented on KAFKA-13699:
---
Hi [~lqxshay] thanks for filing the ticke
guozhangwang commented on a change in pull request #11796:
URL: https://github.com/apache/kafka/pull/11796#discussion_r817035430
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/TopologyConfig.java
##
@@ -116,14 +123,30 @@ public T
[
https://issues.apache.org/jira/browse/KAFKA-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499691#comment-17499691
]
Matthias J. Sax commented on KAFKA-13699:
-
That's my understanding, too. Seems w
junrao merged pull request #11814:
URL: https://github.com/apache/kafka/pull/11814
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr..
bbejeck commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-1055767958
Merged to trunk, 3.0 and 3.1 branches
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499697#comment-17499697
]
Bill Bejeck commented on KAFKA-8659:
Merged to trunk, 3.1, and 3.0 branches
> SetSch
wcarlson5 commented on pull request #10311:
URL: https://github.com/apache/kafka/pull/10311#issuecomment-1055820659
Can we cherry pick with back to 2.6 as well?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mimaison commented on pull request #11572:
URL: https://github.com/apache/kafka/pull/11572#issuecomment-1055821359
@rhauch Can you take a look? It would be great to get this in 3.2. Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499736#comment-17499736
]
Walker Carlson commented on KAFKA-12462:
This also affects 2.6
> Threads in PEN
[
https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson updated KAFKA-12462:
---
Affects Version/s: 2.6.0
> Threads in PENDING_SHUTDOWN entering a rebalance can cause an ill
[
https://issues.apache.org/jira/browse/KAFKA-13678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499753#comment-17499753
]
Matthias J. Sax commented on KAFKA-13678:
-
We have a different use case in mind:
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499755#comment-17499755
]
Guram Savinov edited comment on KAFKA-7500 at 3/1/22, 8:45 PM:
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499755#comment-17499755
]
Guram Savinov commented on KAFKA-7500:
--
[~ryannedolan] could you explain, why the KI
ableegoldman commented on pull request #11812:
URL: https://github.com/apache/kafka/pull/11812#issuecomment-1055850357
Test failures are unrelated, will merge
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
ableegoldman merged pull request #11812:
URL: https://github.com/apache/kafka/pull/11812
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsu
ableegoldman commented on pull request #10311:
URL: https://github.com/apache/kafka/pull/10311#issuecomment-1055859746
> Can we cherry pick with back to 2.6 as well?
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
ableegoldman commented on pull request #11812:
URL: https://github.com/apache/kafka/pull/11812#issuecomment-1055862672
Merged to trunk
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specifi
ableegoldman commented on pull request #11824:
URL: https://github.com/apache/kafka/pull/11824#issuecomment-1055862814
All test failures are unrelated, with no failures of the highly-flaky
NamedTopologyIntegrationTests -- will merge
--
This is an automated message from the Apache Git Ser
ableegoldman merged pull request #11824:
URL: https://github.com/apache/kafka/pull/11824
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsu
ableegoldman commented on pull request #11824:
URL: https://github.com/apache/kafka/pull/11824#issuecomment-1055865706
Merged to trunk
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specifi
ableegoldman commented on a change in pull request #11823:
URL: https://github.com/apache/kafka/pull/11823#discussion_r817148861
##
File path: streams/src/test/resources/log4j.properties
##
@@ -18,9 +18,18 @@ log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appende
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499777#comment-17499777
]
Guozhang Wang commented on KAFKA-13694:
---
[~RivenSun] I think that's a good point,
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499791#comment-17499791
]
Guozhang Wang commented on KAFKA-13694:
---
Actually my previous suggestion has a fla
ableegoldman opened a new pull request #11827:
URL: https://github.com/apache/kafka/pull/11827
This test has been failing somewhat regularly due to going into the ERROR
state before reaching RUNNING during the startup phase. The problem is that we
are reusing the `DELAYED_INPUT_STREAM` top
ableegoldman commented on pull request #11827:
URL: https://github.com/apache/kafka/pull/11827#issuecomment-1055939422
Call for review @guozhangwang @wcarlson5
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
vvcephei opened a new pull request #11828:
URL: https://github.com/apache/kafka/pull/11828
I saw one isolated test failure for these tests, but I couldn't confirm
whether the result was missing a whole partition or whether the iterator for
the partition was empty, so I'm adding the actual
rhauch commented on a change in pull request #11797:
URL: https://github.com/apache/kafka/pull/11797#discussion_r816108391
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/RetryUtil.java
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Found
lihaosky opened a new pull request #11829:
URL: https://github.com/apache/kafka/pull/11829
Add processor metadata to be committed with offset to broker. Adding this so
that we can store last processed window time gracefully.
### Committer Checklist (excluded from commit message)
-
C0urante commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r817270150
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10532:
--
Labels: new-streams-runtime-should-fix newbie++ (was: newbie++)
> Do not wipe state store und
[
https://issues.apache.org/jira/browse/KAFKA-10199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10199:
--
Labels: new-streams-runtime-should-fix (was: )
> Separate state restoration into separate thr
C0urante commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r817274558
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java
##
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apa
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10357:
--
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> Handle accidental deletio
[
https://issues.apache.org/jira/browse/KAFKA-12370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12370:
--
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> Refactor KafkaStreams exp
[
https://issues.apache.org/jira/browse/KAFKA-10575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10575:
--
Labels: new-streams-runtime-should-fix (was: )
> StateRestoreListener#onRestoreEnd should alw
[
https://issues.apache.org/jira/browse/KAFKA-10829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10829:
--
Labels: new-streams-runtime-should-fix (was: )
> Kafka Streams handle produce exception impro
[
https://issues.apache.org/jira/browse/KAFKA-10410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10410:
--
Labels: new-streams-runtime-should-fix (was: )
> OnRestoreStart disappeared from StateRestore
[
https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7663:
-
Labels: new-streams-runtime-should-fix (was: )
> Custom Processor supplied on addGlobalStore is
[
https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8023:
-
Labels: new-streams-runtime-should-fix performance (was: performance)
> Improve global state sto
[
https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8037:
-
Labels: new-streams-runtime-should-fix pull-request-available (was:
pull-request-available)
> K
C0urante commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r817276211
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -1415,4 +1415,21 @@ public static boolean isBlank(String str) {
[
https://issues.apache.org/jira/browse/KAFKA-8023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499831#comment-17499831
]
Guozhang Wang commented on KAFKA-8023:
--
One idea I'm having at the moment is that wh
[
https://issues.apache.org/jira/browse/KAFKA-12812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12812:
--
Labels: new-streams-runtime-should-fix (was: )
> Consider refactoring state store registratio
[
https://issues.apache.org/jira/browse/KAFKA-12693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12693:
--
Labels: new-streams-runtime-should-fix streams (was: streams)
> Consecutive rebalances with z
[
https://issues.apache.org/jira/browse/KAFKA-10688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10688:
--
Labels: new-streams-runtime-should-fix (was: )
> Handle accidental truncation of repartition
[
https://issues.apache.org/jira/browse/KAFKA-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10294:
--
Labels: new-streams-runtime-should-fix (was: )
> Consider whether some of ProcessorStateExcep
[
https://issues.apache.org/jira/browse/KAFKA-10263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10263:
--
Labels: new-streams-runtime-should-fix (was: )
> Do not create standbys for those revoking ac
[
https://issues.apache.org/jira/browse/KAFKA-12738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12738:
--
Labels: new-streams-runtime-should-fix (was: )
> Improved error handling for better at-least-
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13295:
--
Labels: eos new-streams-runtime-should-fix (was: eos)
> Long restoration times for new tasks
1 - 100 of 124 matches
Mail list logo