showuon opened a new pull request, #12334:
URL: https://github.com/apache/kafka/pull/12334
New records handled in this PR:
`FEATURE_LEVEL_RECORD`: featureLevels/FEATURE_NAME -> level
`BROKER_REGISTRATION_CHANGE_RECORD`:
-> brokers/BROKER_ID/isFenced -> true/false
-> brokers
showuon closed pull request #12334: KAFKA-13981: Adding new record type handler
in metadata shell
URL: https://github.com/apache/kafka/pull/12334
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603403#comment-17603403
]
dengziming commented on KAFKA-14152:
> it must catch up to the current metadata befo
showuon opened a new pull request, #12631:
URL: https://github.com/apache/kafka/pull/12631
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing
[
https://issues.apache.org/jira/browse/KAFKA-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14115:
Fix Version/s: 3.2.3
(was: 3.2.2)
> Password configs are logged in plaintex
[
https://issues.apache.org/jira/browse/KAFKA-14136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14136:
Fix Version/s: 3.2.3
(was: 3.2.2)
> AlterConfigs in KRaft does not generate
[
https://issues.apache.org/jira/browse/KAFKA-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14111:
Fix Version/s: 3.2.3
(was: 3.2.2)
> Dynamic config update fails for "passwo
[
https://issues.apache.org/jira/browse/KAFKA-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14107:
Fix Version/s: 3.2.3
(was: 3.2.2)
> Upgrade Jetty for CVE fixes
> -
[
https://issues.apache.org/jira/browse/KAFKA-14149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14149:
Fix Version/s: 3.2.3
(was: 3.2.2)
> Broken DynamicBrokerReconfigurationTest
[
https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-14196:
Fix Version/s: 3.2.3
(was: 3.2.2)
> Duplicated consumption during rebalance
showuon commented on PR #12626:
URL: https://github.com/apache/kafka/pull/12626#issuecomment-1245023780
Failed tests are unrelated:
```
org.apache.kafka.common.network.SslTransportLayerTest.[1]
tlsProtocol=TLSv1.2, useInlinePem=false
kafka.test.ClusterTestExtensionsTest.[1]
showuon merged PR #12626:
URL: https://github.com/apache/kafka/pull/12626
--
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...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14208:
--
Fix Version/s: 3.2.2
> KafkaConsumer#commitAsync throws unexpected WakeupException
> -
[
https://issues.apache.org/jira/browse/KAFKA-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14208.
---
Resolution: Fixed
> KafkaConsumer#commitAsync throws unexpected WakeupException
> --
[
https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14196.
---
Resolution: Fixed
> Duplicated consumption during rebalance, causing OffsetValidationTest to act
>
[
https://issues.apache.org/jira/browse/KAFKA-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14196:
--
Fix Version/s: 3.2.2
(was: 3.2.3)
> Duplicated consumption during rebalance, ca
divijvaidya commented on code in PR #12590:
URL: https://github.com/apache/kafka/pull/12590#discussion_r969339721
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -1933,11 +1941,81 @@ private Map
topicPartitionTags(TopicPartition tp) {
divijvaidya commented on code in PR #12590:
URL: https://github.com/apache/kafka/pull/12590#discussion_r969340204
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -1933,11 +1941,81 @@ private Map
topicPartitionTags(TopicPartition tp) {
divijvaidya commented on code in PR #12590:
URL: https://github.com/apache/kafka/pull/12590#discussion_r969341737
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -1933,11 +1941,81 @@ private Map
topicPartitionTags(TopicPartition tp) {
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969349691
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -356,6 +381,95 @@ private void mergeDuplicateSourceNodes() {
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969351766
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -270,17 +277,12 @@ private void maybeAddNodeForOptimizationMetada
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969353364
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -305,6 +307,36 @@ public void buildAndOptimizeTopology(final bool
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969353780
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software Foundation
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969358545
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -1644,6 +1668,29 @@ private Map getClientCustomProps() {
return props;
}
+
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969371482
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java:
##
@@ -181,13 +181,22 @@ public KStream join(final
KStream lhs,
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969371482
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java:
##
@@ -181,13 +181,22 @@ public KStream join(final
KStream lhs,
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969391230
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -663,6 +663,12 @@ public class StreamsConfig extends AbstractConfig {
public static fin
cadonna commented on code in PR #12449:
URL: https://github.com/apache/kafka/pull/12449#discussion_r969376097
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImplTest.java:
##
@@ -287,7 +279,7 @@ public void shouldGetExistingThreadLeve
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969484570
##
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java:
##
@@ -1263,6 +1263,37 @@ public void testInvalidSecurityProtocol() {
assertTrue(ce.
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pritam Kumar updated KAFKA-14220:
-
Description:
Issue:
In case of the revocation of partitions, the updation of "partition count"
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969520183
##
streams/src/test/java/org/apache/kafka/streams/integration/SelfJoinUpgradeIntegrationTest.java:
##
@@ -0,0 +1,277 @@
+/*
+ * Licensed to the Apache Software Foundati
vpapavas commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r969358545
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -1644,6 +1668,29 @@ private Map getClientCustomProps() {
return props;
}
+
divijvaidya commented on PR #12620:
URL: https://github.com/apache/kafka/pull/12620#issuecomment-1245356187
I did some analysis on what has changed and here is my summary:
ZK 3.7.1 [contains CVE
fixes](https://zookeeper.apache.org/doc/r3.7.1/releasenotes.html) for:
1. Jackson-datab
ijuma commented on code in PR #12630:
URL: https://github.com/apache/kafka/pull/12630#discussion_r969605501
##
docs/upgrade.html:
##
@@ -61,6 +61,11 @@ Upgrading to
3.3.0 from any vers
+Note that upgrading client to 3.3.0 would introduce a new Sticky
Partitioner, des
ijuma commented on code in PR #12630:
URL: https://github.com/apache/kafka/pull/12630#discussion_r969605501
##
docs/upgrade.html:
##
@@ -61,6 +61,11 @@ Upgrading to
3.3.0 from any vers
+Note that upgrading client to 3.3.0 would introduce a new Sticky
Partitioner, des
ijuma commented on code in PR #12630:
URL: https://github.com/apache/kafka/pull/12630#discussion_r969605501
##
docs/upgrade.html:
##
@@ -61,6 +61,11 @@ Upgrading to
3.3.0 from any vers
+Note that upgrading client to 3.3.0 would introduce a new Sticky
Partitioner, des
ijuma commented on code in PR #12630:
URL: https://github.com/apache/kafka/pull/12630#discussion_r969605501
##
docs/upgrade.html:
##
@@ -61,6 +61,11 @@ Upgrading to
3.3.0 from any vers
+Note that upgrading client to 3.3.0 would introduce a new Sticky
Partitioner, des
C0urante commented on code in PR #12602:
URL: https://github.com/apache/kafka/pull/12602#discussion_r969617914
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java:
##
@@ -160,6 +160,33 @@ public void testPoll() {
}
}
+@Te
C0urante commented on PR #12622:
URL: https://github.com/apache/kafka/pull/12622#issuecomment-1245423635
Thanks @kumarpritam863, this is an important fix. I did some research on the
history behind incremental consumer rebalancing and how it relates to the
rebalance listener API, and found t
C0urante commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1245436111
@vamossagar12 there are failing unit tests, can you check those out and ping
us after you've taken a look and fixed any issues?
--
This is an automated message from the Apache Git Serv
vamossagar12 commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1245454894
> @vamossagar12 there are failing unit tests, can you check those out and
ping us after you've taken a look and fixed any issues?
Oops.. Sorry about that. I didn't check the te
C0urante commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r969668198
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java:
##
@@ -78,82 +78,41 @@ public void tearDown() {
public void standardStartup(
yashmayya commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r969737990
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java:
##
@@ -78,82 +78,41 @@ public void tearDown() {
public void standardStartup
jsancio commented on PR #12625:
URL: https://github.com/apache/kafka/pull/12625#issuecomment-1245546902
Thanks @hachikuji . Merging -- the failures look unrelated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
jsancio merged PR #12625:
URL: https://github.com/apache/kafka/pull/12625
--
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...@kafka.apache.
ijuma commented on PR #12620:
URL: https://github.com/apache/kafka/pull/12620#issuecomment-1245588332
Exactly right @divijvaidya, we have generally fixed transitive dependency
issues directly.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
ijuma commented on PR #12620:
URL: https://github.com/apache/kafka/pull/12620#issuecomment-1245590870
One more thing: ZK is going away in AK 4.0. We probably need to do one more
upgrade before that. It may make sense to wait a bit and go straight to 3.8 so
that we benefit from longer suppor
mumrah commented on PR #12627:
URL: https://github.com/apache/kafka/pull/12627#issuecomment-1245603207
This was closed in favor of #12628
--
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 spec
C0urante commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r969819802
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java:
##
@@ -78,155 +74,80 @@ public void tearDown() {
public void standardStartup
yashmayya commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r969848670
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java:
##
@@ -78,155 +74,80 @@ public void tearDown() {
public void standardStartu
C0urante commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r969850848
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTaskTest.java:
##
@@ -78,155 +74,80 @@ public void tearDown() {
public void standardStartup
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14220:
--
Fix Version/s: (was: 3.0.1)
> "partition-count" not getting updated after revocation of pa
[
https://issues.apache.org/jira/browse/KAFKA-14220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14220:
--
Reviewer: Chris Egerton (was: Konstantine Karantasis)
> "partition-count" not getting updated
C0urante closed pull request #12023: Create AbstractLogContext class with
static and dynamic subclasses, remove DynamicPrefixLogger
URL: https://github.com/apache/kafka/pull/12023
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
C0urante commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r969868569
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -164,13 +166,23 @@ public ConsumerCoordinator(GroupRebalanceConfig
C0urante commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r969868569
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -164,13 +166,23 @@ public ConsumerCoordinator(GroupRebalanceConfig
C0urante commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r969868569
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -164,13 +166,23 @@ public ConsumerCoordinator(GroupRebalanceConfig
C0urante commented on code in PR #12020:
URL: https://github.com/apache/kafka/pull/12020#discussion_r969868569
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -164,13 +166,23 @@ public ConsumerCoordinator(GroupRebalanceConfig
jsancio commented on PR #12610:
URL: https://github.com/apache/kafka/pull/12610#issuecomment-1245683056
@ijuma What do you think? Can we merge this?
--
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 t
jsancio merged PR #12414:
URL: https://github.com/apache/kafka/pull/12414
--
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...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-14073.
Resolution: Fixed
> Logging the reason for creating a snapshot
> -
[
https://issues.apache.org/jira/browse/KAFKA-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14206:
---
Fix Version/s: 3.4.0
> Upgrade zookeeper to 3.7.1 to address securit
littlehorse-eng commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r969894336
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -2594,27 +2596,20 @@ public void testDropCommitOnBatchExp
nizhikov opened a new pull request, #12632:
URL: https://github.com/apache/kafka/pull/12632
Implementation of
[KIP-865](https://cwiki.apache.org/confluence/display/KAFKA/KIP-865%3A+Support+--bootstrap-server+in+kafka-streams-application-reset)
Support of `--bootstrap-server` option fo
philipnee opened a new pull request, #12633:
URL: https://github.com/apache/kafka/pull/12633
* This is part of the effort for the consumer refactor project. This PR is
the skeleton of the background thread that runs in the background.
*Testing strategies
Tests will be add once im
philipnee commented on PR #12633:
URL: https://github.com/apache/kafka/pull/12633#issuecomment-1245764396
@hachikuji @guozhangwang - This is the skeleton of the background thread.
Please feel free to pull in reviewers.
--
This is an automated message from the Apache Git Service.
To r
philipnee commented on PR #12633:
URL: https://github.com/apache/kafka/pull/12633#issuecomment-1245767412
@showuon - Seems like you are quite familiar with the kafka consumer. So,
cc you here.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
ijuma commented on code in PR #12392:
URL: https://github.com/apache/kafka/pull/12392#discussion_r969939389
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -2594,27 +2596,20 @@ public void testDropCommitOnBatchExpiry() thro
Huilin Shi created KAFKA-14225:
--
Summary: lazy val exemptSensor Could Cause Deadlock
Key: KAFKA-14225
URL: https://issues.apache.org/jira/browse/KAFKA-14225
Project: Kafka
Issue Type: Bug
hachikuji merged PR #12629:
URL: https://github.com/apache/kafka/pull/12629
--
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...@kafka.apach
[
https://issues.apache.org/jira/browse/KAFKA-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huilin Shi updated KAFKA-14225:
---
Description:
There is a chance to cause deadlock when multiple threads access
ClientRequestQuotaMan
[
https://issues.apache.org/jira/browse/KAFKA-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huilin Shi updated KAFKA-14225:
---
Description:
There is a chance to cause deadlock when multiple threads access
ClientRequestQuotaMan
hshi2022 opened a new pull request, #12634:
URL: https://github.com/apache/kafka/pull/12634
…ntRequestQuotaManager. In the version Scala 2.12, the lazy val
initialization is under the object lock. The deadlock could happen in the
following condition:
In thread a, when ClientRequestQu
artemlivshits commented on code in PR #12630:
URL: https://github.com/apache/kafka/pull/12630#discussion_r969977220
##
docs/upgrade.html:
##
@@ -61,6 +61,11 @@ Upgrading to
3.3.0 from any vers
+Note that upgrading client to 3.3.0 would introduce a new Sticky
Partitio
ijuma merged PR #12630:
URL: https://github.com/apache/kafka/pull/12630
--
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...@kafka.apache.or
ijuma opened a new pull request, #12635:
URL: https://github.com/apache/kafka/pull/12635
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
[
https://issues.apache.org/jira/browse/KAFKA-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-14224:
--
Labels: new-consumer-threading-should-fix (was: )
> Consumer should auto-commit prior to coop
[
https://issues.apache.org/jira/browse/KAFKA-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603743#comment-17603743
]
Guozhang Wang commented on KAFKA-14224:
---
cc [~pnee] I think we can address this by
junrao commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r970071437
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1137,23 +1137,26 @@ public void onCompletion(RecordMetadata metada
guozhangwang commented on code in PR #12600:
URL: https://github.com/apache/kafka/pull/12600#discussion_r970078065
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java:
##
@@ -103,42 +101,75 @@ public void addPendingStandbyTasksToCreate(final
Map
C0urante commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r970065964
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java:
##
@@ -222,25 +224,31 @@ public void
testExecAndHandleRet
jsancio commented on code in PR #12635:
URL: https://github.com/apache/kafka/pull/12635#discussion_r970105135
##
docs/upgrade.html:
##
@@ -81,6 +81,8 @@ Upgrading a
KRaft-based cluster
Notable changes in
3.3.0
+KRaft mode is production ready for new clusters.
ijuma commented on code in PR #12635:
URL: https://github.com/apache/kafka/pull/12635#discussion_r970107576
##
docs/upgrade.html:
##
@@ -81,6 +81,8 @@ Upgrading a
KRaft-based cluster
Notable changes in
3.3.0
+KRaft mode is production ready for new clusters. Se
C0urante commented on code in PR #12632:
URL: https://github.com/apache/kafka/pull/12632#discussion_r970105520
##
core/src/main/scala/kafka/tools/StreamsResetter.java:
##
@@ -213,8 +217,12 @@ private void parseArguments(final String[] args) {
.ofType(String.class)
C0urante commented on PR #12632:
URL: https://github.com/apache/kafka/pull/12632#issuecomment-1245985132
Should we also update the system test
[here](https://github.com/apache/kafka/blob/7b49f175b964c468d5ca7ac9bd70dfd72e6a2e4e/tests/kafkatest/services/streams.py#L547)?
--
This is an auto
jsancio commented on code in PR #12635:
URL: https://github.com/apache/kafka/pull/12635#discussion_r970110217
##
docs/upgrade.html:
##
@@ -81,6 +81,8 @@ Upgrading a
KRaft-based cluster
Notable changes in
3.3.0
+KRaft mode is production ready for new clusters.
jsancio commented on code in PR #12635:
URL: https://github.com/apache/kafka/pull/12635#discussion_r970110815
##
docs/upgrade.html:
##
@@ -81,6 +81,8 @@ Upgrading a
KRaft-based cluster
Notable changes in
3.3.0
+KRaft mode is production ready for new clusters.
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603789#comment-17603789
]
Guozhang Wang commented on KAFKA-10635:
---
Hi [~nicktelford], regarding the broker's
cmccabe opened a new pull request, #12636:
URL: https://github.com/apache/kafka/pull/12636
Convert StandardAuthorizer to use a copy-on-write sorted array rather than a
ConcurrentSkipList. The issue with the skiplist was that because it was
modified while in use by StandardAuthorizer#authori
Jorge Esteban Quilcate Otoya created KAFKA-14226:
Summary: Introduce support for nested structures
Key: KAFKA-14226
URL: https://issues.apache.org/jira/browse/KAFKA-14226
Project: Kafka
Jorge Esteban Quilcate Otoya created KAFKA-14227:
Summary: Support for nested structures: MaskField
Key: KAFKA-14227
URL: https://issues.apache.org/jira/browse/KAFKA-14227
Project: Kafk
Jorge Esteban Quilcate Otoya created KAFKA-14229:
Summary: Support for nested structures: HoistValue
Key: KAFKA-14229
URL: https://issues.apache.org/jira/browse/KAFKA-14229
Project: Kaf
Jorge Esteban Quilcate Otoya created KAFKA-14228:
Summary: Support for nested structures: ValueToKey
Key: KAFKA-14228
URL: https://issues.apache.org/jira/browse/KAFKA-14228
Project: Kaf
Jorge Esteban Quilcate Otoya created KAFKA-14232:
Summary: Support for nested structures: InsertField
Key: KAFKA-14232
URL: https://issues.apache.org/jira/browse/KAFKA-14232
Project: Ka
Jorge Esteban Quilcate Otoya created KAFKA-14230:
Summary: Support for nested structures: Cast
Key: KAFKA-14230
URL: https://issues.apache.org/jira/browse/KAFKA-14230
Project: Kafka
Jorge Esteban Quilcate Otoya created KAFKA-14231:
Summary: Support for nested structures: ReplaceField
Key: KAFKA-14231
URL: https://issues.apache.org/jira/browse/KAFKA-14231
Project: K
jeqo opened a new pull request, #12637:
URL: https://github.com/apache/kafka/pull/12637
KIP-821 initial implementation.
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system
[
https://issues.apache.org/jira/browse/KAFKA-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya reassigned KAFKA-13656:
Assignee: Jorge Esteban Quilcate Otoya
> Connect Transfor
artemlivshits commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r970145425
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1137,23 +1137,26 @@ public void onCompletion(RecordMetadata
artemlivshits commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r970145425
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1137,23 +1137,26 @@ public void onCompletion(RecordMetadata
1 - 100 of 113 matches
Mail list logo
