AndrewJSchofield commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411721121
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -205,6 +205,26 @@ public void wakeup() {
AndrewJSchofield commented on PR #14811:
URL: https://github.com/apache/kafka/pull/14811#issuecomment-1835612791
@junrao This time Java 8, 11 and 21 completed with a handful of unrelated
flaky test failures, but Java 17 timed out. The CI system seems to be a dice
roll at the moment.
--
apoorvmittal10 commented on code in PR #14767:
URL: https://github.com/apache/kafka/pull/14767#discussion_r1411715897
##
core/src/main/scala/kafka/server/ApiVersionManager.scala:
##
@@ -130,7 +133,8 @@ class DefaultApiVersionManager(
brokerFeatures: BrokerFeatures,
apoorvmittal10 commented on code in PR #14767:
URL: https://github.com/apache/kafka/pull/14767#discussion_r1411715680
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -235,14 +235,15 @@ class BrokerServer(
)
clientToControllerChannelManager.start()
apoorvmittal10 commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1411708516
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -4387,7 +4398,52 @@ public FenceProducersResult
fenceProducers(Collection
showuon commented on PR #14892:
URL: https://github.com/apache/kafka/pull/14892#issuecomment-1835580555
@cmccabe @rondagostino , call for review.
--
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
atu-sharm opened a new pull request, #14893:
URL: https://github.com/apache/kafka/pull/14893
Added a method, waitForConfigValueChange, to wait for a configuration value
change in an EmbeddedKafkaCluster after using the incrementalAlterConfigs API.
The test, testSyncTopicConfigs,
showuon opened a new pull request, #14892:
URL: https://github.com/apache/kafka/pull/14892
We should reset `previousBrokerEpoch` to default value for version less than
2 like
showuon commented on PR #14428:
URL: https://github.com/apache/kafka/pull/14428#issuecomment-1835574772
Yes, I agree. Thanks for helping merge 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
vamossagar12 commented on PR #14882:
URL: https://github.com/apache/kafka/pull/14882#issuecomment-1835573531
Looks like this new test failed
```
Error
org.opentest4j.AssertionFailedError: expected:
but was:
Stacktrace
org.opentest4j.AssertionFailedError: expected:
but
mjsax commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1411677019
##
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java:
##
@@ -4387,7 +4398,52 @@ public FenceProducersResult
fenceProducers(Collection
apoorvmittal10 commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411628858
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryProvider.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
apoorvmittal10 commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1411627705
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -957,7 +972,11 @@ public void commitSync(Map offsets,
apoorvmittal10 commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1411627068
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -957,7 +972,11 @@ public void commitSync(Map offsets,
mjsax commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411624321
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryProvider.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
mjsax commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411624321
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryProvider.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411319047
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411317556
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
satishd merged PR #14883:
URL: https://github.com/apache/kafka/pull/14883
--
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:
satishd commented on PR #14883:
URL: https://github.com/apache/kafka/pull/14883#issuecomment-1835422111
There are some unrelated intermittent test failures in Jenkins jobs, merging
it to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
github-actions[bot] commented on PR #13716:
URL: https://github.com/apache/kafka/pull/13716#issuecomment-1835400867
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
github-actions[bot] commented on PR #14316:
URL: https://github.com/apache/kafka/pull/14316#issuecomment-1835400701
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has
Owen-CH-Leung opened a new pull request, #14891:
URL: https://github.com/apache/kafka/pull/14891
As per
jolshan commented on PR #14887:
URL: https://github.com/apache/kafka/pull/14887#issuecomment-1835314327
Looks like there is a checkstyle issue.
--
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
hachikuji commented on PR #14890:
URL: https://github.com/apache/kafka/pull/14890#issuecomment-1835309801
Example of flaky failure:
hachikuji opened a new pull request, #14890:
URL: https://github.com/apache/kafka/pull/14890
Test startup does not assure that all brokers are registered. In flaky
failures, the `DescribeCluster` API does not return a complete list of brokers.
To fix the issue, we add a call to
mjsax commented on code in PR #14626:
URL: https://github.com/apache/kafka/pull/14626#discussion_r1411475602
##
streams/src/main/java/org/apache/kafka/streams/query/MultiVersionedKeyQuery.java:
##
@@ -130,9 +129,9 @@ public Optional toTime() {
/**
* The order of
mjsax opened a new pull request, #14889:
URL: https://github.com/apache/kafka/pull/14889
makeNext() is internal and visibility should not be extended to `public`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
splett2 commented on code in PR #14888:
URL: https://github.com/apache/kafka/pull/14888#discussion_r1411492950
##
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/RefreshingHttpsJwksTest.java:
##
@@ -62,14 +62,14 @@ public class
splett2 opened a new pull request, #14888:
URL: https://github.com/apache/kafka/pull/14888
### What
This test is flaky because `maybeExpediteRefresh` schedules a refresh in a
background thread. Instead pass through a mock executor service so that the
refresh is executed directly.
cmccabe commented on code in PR #14790:
URL: https://github.com/apache/kafka/pull/14790#discussion_r1411471028
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -613,7 +613,16 @@ class Partition(val topicPartition: TopicPartition,
// Only ReplicaAlterDirThread will
kirktrue commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411470319
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -205,6 +205,26 @@ public void wakeup() {
kirktrue commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411470319
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -205,6 +205,26 @@ public void wakeup() {
ijuma commented on PR #14883:
URL: https://github.com/apache/kafka/pull/14883#issuecomment-1835170235
@satishd Do you have cycles to review 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 to
cmccabe commented on code in PR #14790:
URL: https://github.com/apache/kafka/pull/14790#discussion_r1411470125
##
server/src/main/java/org/apache/kafka/server/AssignmentsManager.java:
##
@@ -95,7 +96,10 @@ public void close() throws InterruptedException {
}
public
cmccabe opened a new pull request, #14887:
URL: https://github.com/apache/kafka/pull/14887
(no comment)
--
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,
[
https://issues.apache.org/jira/browse/KAFKA-15527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15527.
-
Resolution: Fixed
> Add reverseRange and reverseAll query over kv-store in IQv2
>
ableegoldman commented on code in PR #14735:
URL: https://github.com/apache/kafka/pull/14735#discussion_r1411413767
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -175,13 +176,15 @@ public class KafkaStreams implements AutoCloseable {
private
ableegoldman opened a new pull request, #14886:
URL: https://github.com/apache/kafka/pull/14886
Minor cleanup to make it easier to follow the restore listener logic.
Currently, the KafkaStreams class tracks two restore listener fields: there is
a non-final, nullable
philipnee commented on PR #14724:
URL: https://github.com/apache/kafka/pull/14724#issuecomment-1834658465
Hi @apoorvmittal10 thanks for writing this PR - also sorry for the delay but
I made the first pass and left some stylistic comments.
--
This is an automated message from the Apache
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411338139
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411331948
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411331257
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411330545
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411328695
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
cmccabe commented on PR #14820:
URL: https://github.com/apache/kafka/pull/14820#issuecomment-1834642532
committed, thanks!
--
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.
cmccabe closed pull request #14820: KAFKA-15886: Always specify directories for
new partition registrations
URL: https://github.com/apache/kafka/pull/14820
--
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
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411319789
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411319047
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411317556
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411316589
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411312954
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryReporter.java:
##
@@ -0,0 +1,952 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
philipnee commented on code in PR #14724:
URL: https://github.com/apache/kafka/pull/14724#discussion_r1411305972
##
clients/src/main/java/org/apache/kafka/clients/ClientTelemetryProvider.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
junrao commented on code in PR #14767:
URL: https://github.com/apache/kafka/pull/14767#discussion_r1411280008
##
core/src/main/scala/kafka/server/BrokerServer.scala:
##
@@ -235,14 +235,15 @@ class BrokerServer(
)
clientToControllerChannelManager.start()
Matthias J. Sax created KAFKA-15951:
---
Summary: MissingSourceTopicException should include topic names
Key: KAFKA-15951
URL: https://issues.apache.org/jira/browse/KAFKA-15951
Project: Kafka
AndrewJSchofield commented on code in PR #14859:
URL: https://github.com/apache/kafka/pull/14859#discussion_r1411266359
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -653,7 +652,7 @@ public Map
committed(final Set();
+
riedelmax commented on code in PR #14544:
URL: https://github.com/apache/kafka/pull/14544#discussion_r1411265076
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/ConsumerGroupMember.java:
##
@@ -545,6 +547,32 @@ public String
AndrewJSchofield commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411254378
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -800,6 +811,11 @@ public void resetTimer() {
AndrewJSchofield commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411253921
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java:
##
@@ -205,6 +205,26 @@ public void wakeup() {
kirktrue commented on code in PR #14859:
URL: https://github.com/apache/kafka/pull/14859#discussion_r1411224159
##
checkstyle/suppressions.xml:
##
@@ -48,7 +48,7 @@
Review Comment:
Thank you for this clean up!
##
kirktrue commented on code in PR #14835:
URL: https://github.com/apache/kafka/pull/14835#discussion_r1411218465
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -800,6 +811,11 @@ public void resetTimer() {
dajac commented on PR #14687:
URL: https://github.com/apache/kafka/pull/14687#issuecomment-1834494230
I cannot get a clean build for this one...
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-15629.
-
Resolution: Fixed
> proposal to introduce IQv2 Query Types: TimestampedKeyQuery and
>
[
https://issues.apache.org/jira/browse/KAFKA-15061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-15061:
---
Assignee: David Jacot
> CoordinatorPartitionWriter should reuse buffer
>
dajac opened a new pull request, #14885:
URL: https://github.com/apache/kafka/pull/14885
This patch adds a ThreadLocal with a GrowableBufferSupplier so that each
writing thread can reuse the same buffer instead of allocating a new one for
each write. The patch relies on existing tests.
mjsax commented on PR #14570:
URL: https://github.com/apache/kafka/pull/14570#issuecomment-1834478535
Thanks for the KIP and PR. Merged to `trunk`.
One more thing: can you do a follow up PR to update the docs?
--
This is an automated message from the Apache Git Service.
To respond
mjsax merged PR #14570:
URL: https://github.com/apache/kafka/pull/14570
--
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:
kirktrue commented on code in PR #14879:
URL: https://github.com/apache/kafka/pull/14879#discussion_r1411200070
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -398,6 +466,38 @@ public class AsyncKafkaConsumer implements
jeffkbkim opened a new pull request, #14884:
URL: https://github.com/apache/kafka/pull/14884
https://issues.apache.org/jira/browse/KAFKA-14505 is not done yet so we need
to disable the system test. Added a comment in the jira to re-enable once it's
implemented.
### Committer
[
https://issues.apache.org/jira/browse/KAFKA-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791759#comment-17791759
]
Jeff Kim commented on KAFKA-14505:
--
disabled test_transactions
[
https://issues.apache.org/jira/browse/KAFKA-13621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-13621.
Resolution: Duplicate
> Resign leader on network partition
>
[
https://issues.apache.org/jira/browse/KAFKA-15911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-15911:
---
Affects Version/s: 3.7.0
> KRaft quorum leader should make sure the
[
https://issues.apache.org/jira/browse/KAFKA-15489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-15489:
---
Fix Version/s: 3.7.0
> split brain in KRaft cluster
>
jsancio merged PR #14428:
URL: https://github.com/apache/kafka/pull/14428
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-15890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15890:
--
Summary: Consumer.poll with long timeout unaware of assigned partitions
(was:
[
https://issues.apache.org/jira/browse/KAFKA-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791742#comment-17791742
]
Philip Nee edited comment on KAFKA-10840 at 11/30/23 7:03 PM:
--
Hey
[
https://issues.apache.org/jira/browse/KAFKA-10840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791742#comment-17791742
]
Philip Nee commented on KAFKA-10840:
Hey [~ChrisEgerton] - Seems like you've been working on
cmccabe commented on code in PR #14628:
URL: https://github.com/apache/kafka/pull/14628#discussion_r1411139366
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -1048,20 +1054,15 @@ class KafkaServer(
*
* @return The brokerId.
*/
- private def
ijuma opened a new pull request, #14883:
URL: https://github.com/apache/kafka/pull/14883
The highlight is full support for Java 21, full release notes below:
* https://docs.gradle.org/8.4/release-notes.html
* https://docs.gradle.org/8.5/release-notes.html
### Committer
cmccabe merged PR #14860:
URL: https://github.com/apache/kafka/pull/14860
--
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:
AndrewJSchofield closed pull request #14811: KAFKA-15831: KIP-1000 protocol and
admin client
URL: https://github.com/apache/kafka/pull/14811
--
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
AndrewJSchofield commented on PR #14811:
URL: https://github.com/apache/kafka/pull/14811#issuecomment-1834320812
I think so. After 8 hours. I will try resubmitting now (which means it will
run overnight for me). In the event that it's still problematic, I'll make a
fresh PR and try again.
cmccabe commented on PR #14860:
URL: https://github.com/apache/kafka/pull/14860#issuecomment-1834306862
> Can we also fix the builder version handling here?
> With this fixed, LGTM
Good catch. The best way to fix this would be to add "ignorable" to the JSON
definition, so that it
[
https://issues.apache.org/jira/browse/KAFKA-15946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15946:
---
Summary: AsyncKafkaConsumer should retry commits on the application thread
instead of auto-retry
junrao commented on PR #14811:
URL: https://github.com/apache/kafka/pull/14811#issuecomment-1834296289
@AndrewJSchofield : It seems that the last build timed out?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
hachikuji merged PR #14875:
URL: https://github.com/apache/kafka/pull/14875
--
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:
jeffkbkim commented on code in PR #14849:
URL: https://github.com/apache/kafka/pull/14849#discussion_r1411063985
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorShard.java:
##
@@ -47,4 +47,15 @@ default void
vamossagar12 opened a new pull request, #14882:
URL: https://github.com/apache/kafka/pull/14882
Adding IT for the case when a static member temporarily leaves the group and
another member replaces it.
--
This is an automated message from the Apache Git Service.
To respond to the message,
dajac closed pull request #14819: MINOR: Fix a few reconciliation bugs
URL: https://github.com/apache/kafka/pull/14819
--
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
lucasbru commented on code in PR #14864:
URL: https://github.com/apache/kafka/pull/14864#discussion_r1410975879
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1791,6 +1794,74 @@ protected int processStreamThread(final
Consumer consumer) {
OmniaGM opened a new pull request, #14881:
URL: https://github.com/apache/kafka/pull/14881
- Extended `LogManager.getOrCreateLog` to accept the target directory's ID.
At this level, we assume that the directory id is online to keep
`getOrCreateLog` simple.
- Fixed
OmniaGM closed pull request #14880: KAFKA-15365: Broker-side replica management
changes
URL: https://github.com/apache/kafka/pull/14880
--
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
mjsax commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1410963954
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -957,7 +972,11 @@ public void commitSync(Map offsets, Duration
mjsax commented on code in PR #14843:
URL: https://github.com/apache/kafka/pull/14843#discussion_r1410962382
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -957,7 +972,11 @@ public void commitSync(Map offsets, Duration
[
https://issues.apache.org/jira/browse/KAFKA-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-15858:
--
Attachment: image.png
> Broker stays fenced until all assignments are correct
>
[
https://issues.apache.org/jira/browse/KAFKA-15858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-15858:
--
Attachment: (was: image.png)
> Broker stays fenced until all assignments are correct
>
OmniaGM opened a new pull request, #14880:
URL: https://github.com/apache/kafka/pull/14880
- Extended `LogManager.getOrCreateLog` to accept the target directory's ID.
At this level, we assume that the directory id is online to keep
`getOrCreateLog` simple.
- Fixed
lianetm commented on code in PR #14857:
URL: https://github.com/apache/kafka/pull/14857#discussion_r1410941917
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -365,6 +366,16 @@ private void
dajac commented on code in PR #14857:
URL: https://github.com/apache/kafka/pull/14857#discussion_r1410931685
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -365,6 +366,16 @@ private void
cadonna opened a new pull request, #14879:
URL: https://github.com/apache/kafka/pull/14879
*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
1 - 100 of 141 matches
Mail list logo
