yashmayya commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r970342727
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporterTest.java:
##
@@ -78,4 +68,41 @@ public void testGetFutures() {
yashmayya commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r970342561
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java:
##
@@ -250,97 +258,90 @@ public void
yashmayya commented on code in PR #12615:
URL: https://github.com/apache/kafka/pull/12615#discussion_r970342294
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperatorTest.java:
##
@@ -222,25 +224,31 @@ public void
artemlivshits commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r970291640
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1129,31 +1129,34 @@ public void
junrao commented on code in PR #12570:
URL: https://github.com/apache/kafka/pull/12570#discussion_r970263402
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/RecordAccumulatorTest.java:
##
@@ -1129,31 +1129,34 @@ public void onCompletion(RecordMetadata
showuon commented on PR #12589:
URL: https://github.com/apache/kafka/pull/12589#issuecomment-1246131692
Agree. Closed
--
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
showuon closed pull request #12589: KAFKA-14197: use raft error
RaftBatchTooLargeException instead of exi…
URL: https://github.com/apache/kafka/pull/12589
--
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
dengziming commented on PR #12589:
URL: https://github.com/apache/kafka/pull/12589#issuecomment-1246128861
This is already fixed, we can close it.
--
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
showuon commented on PR #12620:
URL: https://github.com/apache/kafka/pull/12620#issuecomment-1246111859
Make sense to me. Thank you all. I'll close this PR then.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
showuon closed pull request #12620: KAFKA-14206: upgrade zookeeper version to
3.7.1
URL: https://github.com/apache/kafka/pull/12620
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-14224:
Description: With the old "eager" reassignment logic, we always revoked all
partitions
guozhangwang commented on code in PR #12555:
URL: https://github.com/apache/kafka/pull/12555#discussion_r970140299
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java:
##
@@ -305,6 +305,32 @@ public void buildAndOptimizeTopology(final
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
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
[
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
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
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:
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-14232:
Summary: Support for nested structures: InsertField
Key: KAFKA-14232
URL: https://issues.apache.org/jira/browse/KAFKA-14232
Project:
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:
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:
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:
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603789#comment-17603789
]
Guozhang Wang commented on KAFKA-10635:
---
Hi [~nicktelford], regarding the broker's behavior:
>
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.
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.
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
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)
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.
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.
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603743#comment-17603743
]
Guozhang Wang commented on KAFKA-14224:
---
cc [~pnee] I think we can address this by always pairing
[
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
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)
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:
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
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
[
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
[
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
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:
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
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()
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
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
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
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
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
[
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
[
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
>
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:
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
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
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
[
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
[
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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() {
}
}
+
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,
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,
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,
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,
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.
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_r969520183
##
streams/src/test/java/org/apache/kafka/streams/integration/SelfJoinUpgradeIntegrationTest.java:
##
@@ -0,0 +1,277 @@
+/*
+ * Licensed to the Apache Software
[
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_r969484570
##
streams/src/test/java/org/apache/kafka/streams/StreamsConfigTest.java:
##
@@ -1263,6 +1263,37 @@ public void testInvalidSecurityProtocol() {
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
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
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_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_r969353780
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java:
##
@@ -0,0 +1,172 @@
+/*
+ * Licensed to the Apache Software
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
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
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() {
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) {
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_r969339721
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -1933,11 +1941,81 @@ private Map
topicPartitionTags(TopicPartition tp) {
[
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,
[
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-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-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
>
1 - 100 of 114 matches
Mail list logo
