[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499939#comment-17499939
]
Guram Savinov edited comment on KAFKA-7500 at 3/2/22, 7:48 AM:
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499939#comment-17499939
]
Guram Savinov commented on KAFKA-7500:
--
The question is: does mm2 use target topic o
ableegoldman commented on a change in pull request #11813:
URL: https://github.com/apache/kafka/pull/11813#discussion_r817412782
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -230,53 +
ableegoldman commented on pull request #11823:
URL: https://github.com/apache/kafka/pull/11823#issuecomment-1056310081
Merged to trunk -- thanks @showuon and @guozhangwang !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
ableegoldman merged pull request #11823:
URL: https://github.com/apache/kafka/pull/11823
--
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
guozhangwang commented on a change in pull request #11802:
URL: https://github.com/apache/kafka/pull/11802#discussion_r817311291
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java
##
@@ -0,0 +1,311 @@
+/*
+ * Licensed to
guozhangwang commented on a change in pull request #11802:
URL: https://github.com/apache/kafka/pull/11802#discussion_r817302405
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java
##
@@ -0,0 +1,311 @@
+/*
+ * Licensed to
vvcephei merged pull request #11828:
URL: https://github.com/apache/kafka/pull/11828
--
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
vvcephei commented on pull request #11828:
URL: https://github.com/apache/kafka/pull/11828#issuecomment-1056073684
The test failures were unrelated:
```
Build / ARM /
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest.shouldRemoveOneNamedTopologyWhileAnotherContinu
C0urante commented on pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#issuecomment-1056069349
Thanks @tombentley!
--
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
[
https://issues.apache.org/jira/browse/KAFKA-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-8951:
-
Labels: new-rebalance-should-fix (was: )
> Avoid unnecessary rebalances and downtime for "safe"
C0urante commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r817294374
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,46 @@
protected SourceConnectorContext
C0urante commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r817294240
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/TransactionContext.java
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Softw
C0urante commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r817294047
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/TransactionContext.java
##
@@ -0,0 +1,55 @@
+/*
+ * Licensed to the Apache Softw
C0urante commented on a change in pull request #11773:
URL: https://github.com/apache/kafka/pull/11773#discussion_r817293215
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,46 @@
protected SourceConnectorContext
[
https://issues.apache.org/jira/browse/KAFKA-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499849#comment-17499849
]
RivenSun commented on KAFKA-13694:
--
Hi [~guozhang] Thanks for your reply.
I will create
C0urante commented on pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#issuecomment-1056061959
Thanks for taking a look, @tombentley. Ready for another pass when you have
time.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
C0urante commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r817289657
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FenceProducersResult.java
##
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software
showuon commented on a change in pull request #11788:
URL: https://github.com/apache/kafka/pull/11788#discussion_r817287946
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java
##
@@ -205,25 +208,31 @@
/** metric.reporters */
publ
C0urante commented on a change in pull request #11777:
URL: https://github.com/apache/kafka/pull/11777#discussion_r817287679
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -6281,6 +6284,30 @@ public void
testClientSideTimeou
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499835#comment-17499835
]
Ryanne Dolan commented on KAFKA-7500:
-
[~gsavinov] mm2 cannot guarantee that the down
[
https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-7996:
-
Labels: needs-kip new-streams-runtime-should-fix (was: needs-kip)
> KafkaStreams does not pass t
[
https://issues.apache.org/jira/browse/KAFKA-10563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-10563:
--
Labels: new-streams-runtime-should-fix (was: )
> Make sure task directories don't remain lock
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-9062:
-
Labels: new-streams-runtime-should-fix (was: )
> Handle stalled writes to RocksDB
>
[
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
[
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-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-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-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-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-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-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: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-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-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-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-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-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
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-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
[
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
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
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)
-
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
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
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
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
[
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
[
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,
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
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 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-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 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 #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 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 #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
[
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
[
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-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-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-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
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
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
[
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
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
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..
[
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
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=17499683#comment-17499683
]
Guozhang Wang commented on KAFKA-13699:
---
Hi [~lqxshay] thanks for filing the ticke
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
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
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
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 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
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
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
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
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
[
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
[
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-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-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-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-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: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-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-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: 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 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 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 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-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-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
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=17499610#comment-17499610
]
Mickael Maison commented on KAFKA-13658:
[~cadonna] Thanks for heads up. Yeah we
1 - 100 of 124 matches
Mail list logo
