AndrewJSchofield merged PR #20436:
URL: https://github.com/apache/kafka/pull/20436
--
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...@kafk
kumarpritam863 commented on PR #19341:
URL: https://github.com/apache/kafka/pull/19341#issuecomment-3235698663
Sure @mimaison but in the meanwhile can you please share your view on that
thread it would really be very helpful.
--
This is an automated message from the Apache Git Service.
To
github-actions[bot] commented on PR #19621:
URL: https://github.com/apache/kafka/pull/19621#issuecomment-3235589457
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #18903:
URL: https://github.com/apache/kafka/pull/18903#issuecomment-3235589702
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20359:
URL: https://github.com/apache/kafka/pull/20359#issuecomment-323559
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20393:
URL: https://github.com/apache/kafka/pull/20393#issuecomment-3235588699
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19513:
URL: https://github.com/apache/kafka/pull/19513#issuecomment-3235589490
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3235588735
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #19703:
URL: https://github.com/apache/kafka/pull/19703#issuecomment-3235589380
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20197:
URL: https://github.com/apache/kafka/pull/20197#issuecomment-3235589069
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20388:
URL: https://github.com/apache/kafka/pull/20388#issuecomment-3235588781
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
kirktrue commented on PR #20324:
URL: https://github.com/apache/kafka/pull/20324#issuecomment-3235313726
FYI: test failures appear related to the broader flakiness of the tests over
the last seven days:
- `AclControlManagerTest.testDeleteExceedsMaxRecords()`: [10%
flaky](https://deve
yunchipang commented on code in PR #20396:
URL: https://github.com/apache/kafka/pull/20396#discussion_r2308815855
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -240,13 +250,16 @@ public static void main(String[] args) throws Exception {
C
mjsax commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3235299164
If you want to divide the work, a good approach would be to first split up
the work to update all integrations test, before we merge any actual code
changes?
--
This is an automated mess
mjsax commented on code in PR #20293:
URL: https://github.com/apache/kafka/pull/20293#discussion_r2308815743
##
tools/src/test/java/org/apache/kafka/tools/streams/ResetStreamsGroupOffsetTest.java:
##
@@ -738,4 +755,26 @@ private static void produceMessagesOnTwoPartitions(final
mjsax commented on code in PR #20293:
URL: https://github.com/apache/kafka/pull/20293#discussion_r2308814874
##
tools/src/test/java/org/apache/kafka/tools/streams/DeleteStreamsGroupOffsetTest.java:
##
@@ -436,4 +440,26 @@ private StreamsGroupCommand.StreamsGroupService
getStrea
mjsax commented on PR #20260:
URL: https://github.com/apache/kafka/pull/20260#issuecomment-3235275904
Seems this issue is getting resolved via
https://github.com/apache/kafka/pull/19513/commits/6295c8a98262624e5415f581e12530aa602ab95b
Should we close this PR, or wait until#19513 got m
[
https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016901#comment-18016901
]
Matthias J. Sax commented on KAFKA-16801:
-
Sweet! – Thanks for letting us know [
kirktrue commented on code in PR #20363:
URL: https://github.com/apache/kafka/pull/20363#discussion_r2308712762
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -140,7 +145,7 @@ public abstract class AbstractMembershipMan
dejan2609 commented on PR #19513:
URL: https://github.com/apache/kafka/pull/19513#issuecomment-3235106658
Update: yet another commit is added (that solves this JIRA sub-ticket):
- https://issues.apache.org/jira/browse/KAFKA-16801 Streams upgrade :test
target doesn't find any junit tests
[
https://issues.apache.org/jira/browse/KAFKA-16801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016895#comment-18016895
]
Dejan Stojadinović commented on KAFKA-16801:
Hi everybody,
I just discover
apoorvmittal10 opened a new pull request, #20436:
URL: https://github.com/apache/kafka/pull/20436
These tests were written while finalizing approach for making inflight state
class thread safe but later approach changed and the lock is now always
required by SharePartition to change infligh
chia7712 commented on PR #20424:
URL: https://github.com/apache/kafka/pull/20424#issuecomment-3234969859
> I still don't get this output... Not sure why
That’s strange. I tested JDK 17, 21, and 24 according to [this
comment](https://github.com/apache/kafka/pull/20424?utm_source=chatgp
[
https://issues.apache.org/jira/browse/KAFKA-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016885#comment-18016885
]
Dejan Stojadinović commented on KAFKA-16800:
Hi all,
(i) I'm linking Gradle
[
https://issues.apache.org/jira/browse/KAFKA-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016883#comment-18016883
]
Kirk True commented on KAFKA-18087:
---
We continue to catch issues with the `AsyncKafkaC
[
https://issues.apache.org/jira/browse/KAFKA-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016882#comment-18016882
]
Chang Chi Hsu commented on KAFKA-18061:
---
Hi [~linsiyuan],
Would it be possible f
mjsax commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2308509485
##
server-common/src/test/java/org/apache/kafka/server/util/CommandLineUtilsTest.java:
##
@@ -55,35 +55,35 @@ public void testParseEmptyArgAsValid() {
List argAr
mjsax commented on PR #20424:
URL: https://github.com/apache/kafka/pull/20424#issuecomment-3234880507
I still don't get this output... Not sure why 🤷
--
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 t
jim0987795064 opened a new pull request, #20435:
URL: https://github.com/apache/kafka/pull/20435
- ""Changes: ""Remove outdated "missing features" references from docs
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
shashankhs11 commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3234745660
That would be awesome! I would really love to collaborate and help resolve
the issue. However, I think collaborating might be a difficult task to tackle,
but I've got a plan.
kevin-wu24 commented on code in PR #20422:
URL: https://github.com/apache/kafka/pull/20422#discussion_r2308337503
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -842,6 +846,7 @@ public void handleException(Throwable exception) {
@Ov
janchilling commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3234649516
Hi @mjsax , @lucasbru , @shashankhs11 ,
I’m happy to share this PR with @shashankhs11, and it would be great if I
can collaborate with him on this.
The main place I got s
[
https://issues.apache.org/jira/browse/KAFKA-19651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19651:
--
Fix Version/s: 4.2.0
> Thread is not marked interrupted even when AsyncKafkaConsumer.close() throws
>
chia7712 commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2308284793
##
build.gradle:
##
@@ -740,6 +740,7 @@ subprojects {
// For more details, refer to
https://github.com/gradle/gradle/issues/13762.
// As a result, we need t
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016858#comment-18016858
]
Arpit Goyal commented on KAFKA-19259:
-
Yes [~kirktrue] sure. Can you share me the p
apoorvmittal10 commented on code in PR #20415:
URL: https://github.com/apache/kafka/pull/20415#discussion_r2307354537
##
docs/upgrade.html:
##
@@ -41,9 +43,51 @@ Notable changes in 4
The PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG in
ProducerConfig was deprecated a
Kirk True created KAFKA-19651:
-
Summary: Thread is not marked interrupted even when
AsyncKafkaConsumer.close() throws InterruptException
Key: KAFKA-19651
URL: https://issues.apache.org/jira/browse/KAFKA-19651
mjsax commented on PR #20424:
URL: https://github.com/apache/kafka/pull/20424#issuecomment-3234426948
Still seeing, but IntelliJ does not highlight anything, and I cannot spot
the issue.
```
> Task :server:compileTestJava
Note:
/Users/matthiassax/IdeaProjects/kafka/server/src/test/
AndrewJSchofield merged PR #20434:
URL: https://github.com/apache/kafka/pull/20434
--
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...@kafk
AndrewJSchofield commented on code in PR #20431:
URL: https://github.com/apache/kafka/pull/20431#discussion_r2308006250
##
tools/src/main/java/org/apache/kafka/tools/ClusterTool.java:
##
@@ -82,9 +83,13 @@ static void execute(String... args) throws Exception {
conne
aheev commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2308137965
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -335,8 +349,18 @@ public ConsumerPerfOptions(String[] args) {
}
if
[
https://issues.apache.org/jira/browse/KAFKA-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-18087:
--
Fix Version/s: (was: 4.2.0)
> Revert unnecessary integration testing of both consumer group protoc
[
https://issues.apache.org/jira/browse/KAFKA-19259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016842#comment-18016842
]
Kirk True commented on KAFKA-19259:
---
[~goyarpit]—I have a proposed fix linked to this
mjsax commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2308051163
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1978,7 +1978,7 @@ public ProductionExceptionHandlerResponse handle(
junrao commented on code in PR #20334:
URL: https://github.com/apache/kafka/pull/20334#discussion_r2308038987
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -716,23 +716,21 @@ public void testInterceptorConstructorClose(GroupProtocol
gr
kevin-wu24 commented on code in PR #20422:
URL: https://github.com/apache/kafka/pull/20422#discussion_r2307970537
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
Review Comment:
I think it should be sufficient to call
`controllerMetrics.upda
chia7712 commented on PR #20421:
URL: https://github.com/apache/kafka/pull/20421#issuecomment-3234132277
@brandboat Perhaps this PR could instead add comments to clarify why it is
ncessary to set both the number of partitions and the replication factor in
broker
--
This is an automated m
kamalcph commented on code in PR #20256:
URL: https://github.com/apache/kafka/pull/20256#discussion_r2307900595
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -2347,6 +2347,7 @@ class ReplicaManager(val config: KafkaConfig,
// Before taking the lock, comput
kamalcph commented on code in PR #20256:
URL: https://github.com/apache/kafka/pull/20256#discussion_r2307889453
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java:
##
@@ -490,8 +479,8 @@ public void onLeadershipChange(Set
partitionsBecomeL
sjhajharia commented on PR #20432:
URL: https://github.com/apache/kafka/pull/20432#issuecomment-3233777844
Hey @ijuma
I spot checked them and indeed none of them seem to be intentional based on
their original PRs where they were introduced. Is there something specific I
must look at?
aheev commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2307648334
##
tests/kafkatest/services/performance/consumer_performance.py:
##
@@ -40,7 +40,7 @@ class ConsumerPerformanceService(PerformanceService):
"socket-buffer-size",
kevin-wu24 commented on code in PR #20422:
URL: https://github.com/apache/kafka/pull/20422#discussion_r2307848113
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -157,8 +164,22 @@ public Long value() {
return new
AndrewJSchofield opened a new pull request, #20434:
URL: https://github.com/apache/kafka/pull/20434
Improve the wording in the upgrade doc slightly. Also fix a tiny annoyance
in the output from the message generator.
--
This is an automated message from the Apache Git Service.
To respond
MahsaSeifikar commented on code in PR #20422:
URL: https://github.com/apache/kafka/pull/20422#discussion_r2307835951
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -157,8 +164,22 @@ public Long value() {
return
brandboat commented on PR #20421:
URL: https://github.com/apache/kafka/pull/20421#issuecomment-3234024772
Hi @lucasbru, the original implementation is right, like @chia7712
mentioned, topic apply default replica factor and partition num from broker
server.
https://github.com/apache/kafka/b
brandboat closed pull request #20421: MINOR: Remove default config in
AutoTopicCreationManager#createStreamsInternalTopics
URL: https://github.com/apache/kafka/pull/20421
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
kevin-wu24 commented on code in PR #20422:
URL: https://github.com/apache/kafka/pull/20422#discussion_r2307788763
##
metadata/src/main/java/org/apache/kafka/controller/metrics/QuorumControllerMetrics.java:
##
@@ -157,8 +164,22 @@ public Long value() {
return new
[
https://issues.apache.org/jira/browse/KAFKA-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-19635.
--
Resolution: Fixed
> Update upgrade.html with the changes in Apache Kafka 4.2
> ---
AndrewJSchofield merged PR #20415:
URL: https://github.com/apache/kafka/pull/20415
--
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...@kafk
AndrewJSchofield commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2307773588
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -335,8 +349,18 @@ public ConsumerPerfOptions(String[] args) {
}
AndrewJSchofield commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2307725001
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -292,13 +296,18 @@ public ConsumerPerfOptions(String[] args) {
.
lucasbru merged PR #20412:
URL: https://github.com/apache/kafka/pull/20412
--
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
apoorvmittal10 commented on code in PR #20415:
URL: https://github.com/apache/kafka/pull/20415#discussion_r2307738086
##
docs/upgrade.html:
##
@@ -41,9 +43,73 @@ Notable changes in 4
The PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG in
ProducerConfig was deprecated a
lucasbru commented on PR #19967:
URL: https://github.com/apache/kafka/pull/19967#issuecomment-3233876098
Thanks a lot for the detailed review @squah-confluent ! This is actually
very helpful
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lucasbru commented on code in PR #19967:
URL: https://github.com/apache/kafka/pull/19967#discussion_r2307714058
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfigManager.java:
##
@@ -52,6 +54,10 @@ public void updateGroupConfig(String groupId, Prop
chia7712 commented on PR #20248:
URL: https://github.com/apache/kafka/pull/20248#issuecomment-3233688652
@DL1231 could you please rebase code to run CI again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
fvaleri commented on PR #20433:
URL: https://github.com/apache/kafka/pull/20433#issuecomment-3233730715
@mimaison @showuon fyi
--
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
fvaleri opened a new pull request, #20433:
URL: https://github.com/apache/kafka/pull/20433
Bump Commons-Lang for CVE-2025-48924.
--
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 comme
ijuma commented on PR #20432:
URL: https://github.com/apache/kafka/pull/20432#issuecomment-3233595698
Have you verified that the overrides were not intentional?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
squah-confluent commented on code in PR #19967:
URL: https://github.com/apache/kafka/pull/19967#discussion_r2307416991
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfigManager.java:
##
@@ -52,6 +54,10 @@ public void updateGroupConfig(String groupI
AndrewJSchofield commented on code in PR #20415:
URL: https://github.com/apache/kafka/pull/20415#discussion_r2307483756
##
docs/upgrade.html:
##
@@ -41,9 +43,51 @@ Notable changes in 4
The PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG in
ProducerConfig was deprecated
squah-confluent commented on code in PR #19967:
URL: https://github.com/apache/kafka/pull/19967#discussion_r2307448948
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1913,6 +1914,11 @@ private CoordinatorResult stream
chia7712 commented on code in PR #20396:
URL: https://github.com/apache/kafka/pull/20396#discussion_r2307348317
##
tools/src/main/java/org/apache/kafka/tools/LogCompactionTester.java:
##
@@ -240,13 +250,16 @@ public static void main(String[] args) throws Exception {
Com
apoorvmittal10 merged PR #20416:
URL: https://github.com/apache/kafka/pull/20416
--
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.
sjhajharia commented on PR #20393:
URL: https://github.com/apache/kafka/pull/20393#issuecomment-3233152594
Adding @chia7712 as he has been helping with tonnes of reviews in this area.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
sjhajharia opened a new pull request, #20432:
URL: https://github.com/apache/kafka/pull/20432
Getting rid of a bunch of `toString` functions in record classes in Storage
Module.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Schubert Fernandes created KAFKA-19650:
--
Summary: Add message key to
org.apache.kafka.clients.producer.RecordMetadata
Key: KAFKA-19650
URL: https://issues.apache.org/jira/browse/KAFKA-19650
Proje
[
https://issues.apache.org/jira/browse/KAFKA-19626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18016754#comment-18016754
]
Jhen-Yung Hsu commented on KAFKA-19626:
---
Add the PR link here, since it is not sho
Yunyung opened a new pull request, #20431:
URL: https://github.com/apache/kafka/pull/20431
This implements [KIP-1147](https://cwiki.apache.org/confluence/x/DguWF) for
kafka-cluster.sh, kafka-leader-election.sh and
kafka-streams-application-reset.sh.
Jira: https://issues.apache.org/ji
chia7712 commented on code in PR #20425:
URL: https://github.com/apache/kafka/pull/20425#discussion_r2306444968
##
storage/src/test/java/org/apache/kafka/server/log/remote/quota/RLMQuotaMetricsTest.java:
##
@@ -58,7 +58,7 @@ public void testClose() {
// Register the s
m1a2st commented on code in PR #20334:
URL: https://github.com/apache/kafka/pull/20334#discussion_r2307048649
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -713,32 +713,6 @@ public void testInterceptorConstructorClose(GroupProtocol
gro
m1a2st commented on code in PR #20334:
URL: https://github.com/apache/kafka/pull/20334#discussion_r2307042233
##
server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java:
##
@@ -137,7 +144,8 @@ public Map
effectiveListenerSecurityProtocolMap(
//
Yunyung commented on code in PR #20385:
URL: https://github.com/apache/kafka/pull/20385#discussion_r2306938202
##
tests/kafkatest/services/performance/consumer_performance.py:
##
@@ -40,7 +40,7 @@ class ConsumerPerformanceService(PerformanceService):
"socket-buffer-size
[
https://issues.apache.org/jira/browse/KAFKA-10093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18015424#comment-18015424
]
Ksolves India Limited edited comment on KAFKA-10093 at 8/28/25 10:13 AM:
-
lucasbru commented on code in PR #20244:
URL: https://github.com/apache/kafka/pull/20244#discussion_r2306898719
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -4363,6 +4401,162 @@ class PlaintextAdminIntegrationTest extends
BaseAdminInte
samarth-ksolves opened a new pull request, #20430:
URL: https://github.com/apache/kafka/pull/20430
This PR updated the running-app.html to:
1. Add missing documentation for Kafka Streams listeners and callbacks.
2. Current docs do not explain or list the available listeners, making
frankvicky merged PR #20418:
URL: https://github.com/apache/kafka/pull/20418
--
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.apac
AndrewJSchofield merged PR #20426:
URL: https://github.com/apache/kafka/pull/20426
--
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...@kafk
Chuckame commented on PR #19816:
URL: https://github.com/apache/kafka/pull/19816#issuecomment-3232482710
Maybe coming back to the root cause of why I need it:
When creating the GraphNode, it needs the build priority to be set. Setting
the value to the parent node works, but I'm not su
Chuckame commented on PR #19816:
URL: https://github.com/apache/kafka/pull/19816#issuecomment-3232461991
Yes, I'm doing reflection for some other things to find out all the
(de)serializers to build a json file showing the serialization layer with all
the types, to be aware of any breaking c
frankvicky commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2306633978
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1978,7 +1978,7 @@ public ProductionExceptionHandlerResponse ha
frankvicky commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2306547196
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1978,7 +1978,7 @@ public ProductionExceptionHandlerResponse ha
lucasbru commented on PR #19400:
URL: https://github.com/apache/kafka/pull/19400#issuecomment-3232351992
@frankvicky: This makes sense, then. So remaining in group means sending the
leave epoch in the static case. Then it is just the code comment that is
misleading and could probably be upd
lucasbru commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3232339210
Sounds good to me. Once @janchilling confirms taking on the whole work, we
can close the other PRs. Note that completing the work does not only involve
removing code, but also porting /
chia7712 commented on code in PR #20424:
URL: https://github.com/apache/kafka/pull/20424#discussion_r2306491803
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java:
##
@@ -1978,7 +1978,7 @@ public ProductionExceptionHandlerResponse hand
JimmyWang6 opened a new pull request, #20429:
URL: https://github.com/apache/kafka/pull/20429
This is a follow-up to #19449, which do the following things:
1. Add document to explain `schema.content` only work for sink connector
when `schemas.enable` set to true.
2. Handle the cas
chia7712 merged PR #20427:
URL: https://github.com/apache/kafka/pull/20427
--
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
abhijeetk88 opened a new pull request, #20428:
URL: https://github.com/apache/kafka/pull/20428
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some
98 matches
Mail list logo
