apoorvmittal10 commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2956996007
@junrao Thanks for reviewing, I have addressed the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957050#comment-17957050
]
Donny Nadolny commented on KAFKA-19012:
---
[~junrao] the earliest producer where we
rreddy-22 commented on code in PR #19910:
URL: https://github.com/apache/kafka/pull/19910#discussion_r2136535090
##
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala:
##
@@ -819,11 +819,14 @@ class TransactionCoordinator(txnConfig: TransactionConfig,
jolshan merged PR #19909:
URL: https://github.com/apache/kafka/pull/19909
--
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.
jolshan merged PR #19931:
URL: https://github.com/apache/kafka/pull/19931
--
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.
github-actions[bot] commented on PR #19882:
URL: https://github.com/apache/kafka/pull/19882#issuecomment-2957575136
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
frankvicky commented on PR #19936:
URL: https://github.com/apache/kafka/pull/19936#issuecomment-2957609016
@mingyen066: Please merge trunk to re-trigger CI.
--
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
github-actions[bot] commented on PR #17732:
URL: https://github.com/apache/kafka/pull/17732#issuecomment-2957594315
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
showuon opened a new pull request, #19939:
URL: https://github.com/apache/kafka/pull/19939
WIP, make sure it won't break anything
--
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 comm
[
https://issues.apache.org/jira/browse/KAFKA-19394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19394:
--
Summary: Failure in ConsumerNetworkThread.initializeResources() can cause
hangs on AsyncKafkaConsumer.
[
https://issues.apache.org/jira/browse/KAFKA-19390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Masahiro Mori updated KAFKA-19390:
--
Description:
Our kafka broker crashed with the following error:
{code:java}
[2025-03-29 09:37:
frankvicky commented on PR #19919:
URL: https://github.com/apache/kafka/pull/19919#issuecomment-2957631945
@Rancho-7
There are some issue that needs to be clarified before modifying
NOTICE-binary.
Could you please revert the change of NOTICE-binary and open a jira ticket
for it?
--
dependabot[bot] opened a new pull request, #19940:
URL: https://github.com/apache/kafka/pull/19940
Bumps [requests](https://github.com/psf/requests) from 2.31.0 to 2.32.4.
Release notes
Sourced from https://github.com/psf/requests/releases";>requests's
releases.
v2.32.4
2
github-actions[bot] commented on PR #19876:
URL: https://github.com/apache/kafka/pull/19876#issuecomment-2957575162
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
frankvicky merged PR #19929:
URL: https://github.com/apache/kafka/pull/19929
--
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
Rancho-7 commented on PR #19919:
URL: https://github.com/apache/kafka/pull/19919#issuecomment-2957676135
> @Rancho-7 There are some issue that needs to be clarified before modifying
NOTICE-binary. Could you please revert the change of NOTICE-binary and open a
jira ticket for it?
Reve
[
https://issues.apache.org/jira/browse/KAFKA-19395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nick Guo updated KAFKA-19395:
-
Summary: The version and license information in the `NOTICE-binary` file
for `JUnit` are inconsistent (
Kirk True created KAFKA-19394:
-
Summary: Failure in ConsumerNetworkThread.initializeResources()
can cause hangs on close
Key: KAFKA-19394
URL: https://issues.apache.org/jira/browse/KAFKA-19394
Project: Ka
kirktrue commented on code in PR #17022:
URL: https://github.com/apache/kafka/pull/17022#discussion_r2136374381
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -779,14 +779,25 @@ public synchronized void
maybeTransitionToError
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136356737
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Utils.java:
##
@@ -20,12 +20,41 @@
import org.apache.kafka.common.TopicPartition;
import java.
junrao commented on code in PR #19862:
URL: https://github.com/apache/kafka/pull/19862#discussion_r2136586587
##
server-common/src/main/java/org/apache/kafka/server/purgatory/DelayedOperation.java:
##
@@ -58,26 +58,15 @@ public DelayedOperation(long delayMs) {
* true, othe
jolshan commented on code in PR #19910:
URL: https://github.com/apache/kafka/pull/19910#discussion_r2136822173
##
core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala:
##
@@ -819,11 +819,14 @@ class TransactionCoordinator(txnConfig: TransactionConfig,
[
https://issues.apache.org/jira/browse/KAFKA-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957422#comment-17957422
]
Luke Chen commented on KAFKA-19359:
---
I've requested for a release in `commons-validato
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957364#comment-17957364
]
Jun Rao commented on KAFKA-19012:
-
Thanks for the info, [~dnadolny].
> Messages ending
junrao commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2957209914
@apoorvmittal10 : Thanks for the experimental results. For Local log fetch,
could you run multiple groups on the same topic? Could you also measure the CPU
usage on the broker?
--
This
apoorvmittal10 commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2957325074
@junrao The importance of the fix is more evident when messages are larger
in size. I produced messages of size 102400 Bytes hence a single share fetch
should have 500 (default) *
apoorvmittal10 commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2957255489
> @apoorvmittal10 : Thanks for the experimental results. For Local log
fetch, could you run multiple groups on the same topic? Could you also measure
the CPU usage on the broker?
apoorvmittal10 commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2957260554
Total 5 * 2GB = 10 GB data read by 5 share groups on 1GB Kafka server in
~130 secs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
Lianet Magrans created KAFKA-19393:
--
Summary: Consolidate consumer assignment state views
Key: KAFKA-19393
URL: https://issues.apache.org/jira/browse/KAFKA-19393
Project: Kafka
Issue Type: I
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136340952
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -84,16 +84,21 @@ public TopicMetadataRequestManager(final
brandboat commented on PR #19933:
URL: https://github.com/apache/kafka/pull/19933#issuecomment-2957377963
AC, gentle ping @chia7712, @jolshan, could you please take a look when you
are available? Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the mes
kirktrue opened a new pull request, #19938:
URL: https://github.com/apache/kafka/pull/19938
Adds a test dependency on
[mock-oauth2-server](https://github.com/navikt/mock-oauth2-server/) for
integration tests for OAuth layer.
--
This is an automated message from the Apache Git Service.
To
Nick Guo created KAFKA-19395:
Summary: The version and license information in the
`NOTICE-binary` file for `JUnit` are inconsistent/
Key: KAFKA-19395
URL: https://issues.apache.org/jira/browse/KAFKA-19395
github-actions[bot] closed pull request #17732: KAFKA-17688 Move
TransactionsTest to storage module
URL: https://github.com/apache/kafka/pull/17732
--
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 th
[
https://issues.apache.org/jira/browse/KAFKA-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lan Ding updated KAFKA-17541:
-
Fix Version/s: 4.2.0
> Improve handling of delivery count
> --
>
>
mjsax merged PR #19832:
URL: https://github.com/apache/kafka/pull/19832
--
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
chia7712 commented on code in PR #19400:
URL: https://github.com/apache/kafka/pull/19400#discussion_r2135830769
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1205,45 +1200,9 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeou
FrankYang0529 opened a new pull request, #19932:
URL: https://github.com/apache/kafka/pull/19932
In [KIP-1143](https://cwiki.apache.org/confluence/x/LwqWF), it deprecated
Endpoint#listenerName and removed org.apache.kafka.network.EndPoint. Certain
parts of the code depend on listener name n
ahuang98 commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2136234763
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2543,13 +2543,16 @@ private void maybeTransition(
} else {
trans
mingyen066 commented on PR #19936:
URL: https://github.com/apache/kafka/pull/19936#issuecomment-2956583980
Thanks @chia7712
I ran the e2e test on my mac and all passed
```
$
TC_PATHS="tests/kafkatest/tests/core/snapshot_test.py::TestSnapshots.test_controller"
bash tests/docke
apoorvmittal10 commented on code in PR #19928:
URL: https://github.com/apache/kafka/pull/19928#discussion_r2136306887
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -808,9 +809,18 @@ private void
releasePartitionLocksAndAddToActionQueue(Set topi
apoorvmittal10 commented on PR #19928:
URL: https://github.com/apache/kafka/pull/19928#issuecomment-2956678794
## Test results for performance:
Setup share groups to read from earliest:
```
bin/kafka-configs.sh --bootstrap-server localhost:9092 --entity-type groups
--entity-name
apoorvmittal10 commented on code in PR #19928:
URL: https://github.com/apache/kafka/pull/19928#discussion_r2136268973
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -808,9 +809,18 @@ private void
releasePartitionLocksAndAddToActionQueue(Set topi
apoorvmittal10 commented on code in PR #19928:
URL: https://github.com/apache/kafka/pull/19928#discussion_r2136306887
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -808,9 +809,18 @@ private void
releasePartitionLocksAndAddToActionQueue(Set topi
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136329921
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -1135,7 +1134,9 @@ CompletableFuture
revokePartitions(Set p
lianetm commented on code in PR #19814:
URL: https://github.com/apache/kafka/pull/19814#discussion_r2132881121
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java:
##
@@ -91,6 +92,13 @@ private enum SubscriptionType {
/* the list of t
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136340952
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -84,16 +84,21 @@ public TopicMetadataRequestManager(final
ahuang98 commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2136234763
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2543,13 +2543,16 @@ private void maybeTransition(
} else {
trans
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136357518
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -84,16 +84,21 @@ public TopicMetadataRequestManager(final
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136355942
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -1135,7 +1134,9 @@ CompletableFuture
revokePartitions(Set p
Chia-Ping Tsai created KAFKA-19392:
--
Summary: `metadata.log.segment.ms` is not applied
Key: KAFKA-19392
URL: https://issues.apache.org/jira/browse/KAFKA-19392
Project: Kafka
Issue Type: Bug
jolshan commented on code in PR #19931:
URL: https://github.com/apache/kafka/pull/19931#discussion_r2135997432
##
docs/design.html:
##
@@ -340,6 +340,18 @@
+The error handling for transactional producer has been standardized which
ensures consistent behavior and clearer er
jolshan commented on code in PR #19931:
URL: https://github.com/apache/kafka/pull/19931#discussion_r2135998371
##
docs/design.html:
##
@@ -340,6 +340,18 @@
+The error handling for transactional producer has been standardized which
ensures consistent behavior and clearer er
nookyo opened a new pull request, #19935:
URL: https://github.com/apache/kafka/pull/19935
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 comme
nookyo closed pull request #19935: Feat/issues 208
URL: https://github.com/apache/kafka/pull/19935
--
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-
junrao commented on code in PR #19928:
URL: https://github.com/apache/kafka/pull/19928#discussion_r2136178608
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -808,9 +809,18 @@ private void
releasePartitionLocksAndAddToActionQueue(Set topi
// then
[
https://issues.apache.org/jira/browse/KAFKA-19299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957043#comment-17957043
]
Uladzislau Blok commented on KAFKA-19299:
-
https://github.com/apache/kafka/pull/
[
https://issues.apache.org/jira/browse/KAFKA-19299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19299:
Description:
[https://github.com/apache/kafka/actions/runs/15082423973/job/42401003258?pr=
lianetm commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136213734
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -1135,7 +1134,9 @@ CompletableFuture
revokePartitions(Set pa
k-raina commented on code in PR #19931:
URL: https://github.com/apache/kafka/pull/19931#discussion_r2136215946
##
docs/design.html:
##
@@ -340,6 +340,18 @@
+The error handling for transactional producer has been standardized which
ensures consistent behavior and clearer er
[
https://issues.apache.org/jira/browse/KAFKA-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-19080:
Summary: The constraint on segment.bytes is not enforced at topic level
(was: The constraint on segment.m
[
https://issues.apache.org/jira/browse/KAFKA-19080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17940821#comment-17940821
]
Jun Rao edited comment on KAFKA-19080 at 6/9/25 8:35 PM:
-
[~iamo
kirktrue commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2136347808
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/TopicMetadataRequestManager.java:
##
@@ -84,16 +84,21 @@ public TopicMetadataRequestManager(final
kamil-adam-nowak commented on PR #17826:
URL: https://github.com/apache/kafka/pull/17826#issuecomment-2955958378
@lianetm @mimaison @frankvicky @FrankYang0529 @gongxuanzhang @chia7712 Can
you please take a second look?
@kamalcph wrote it looked good to him. The problem still exists. The b
chia7712 commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2135853739
##
core/src/main/scala/kafka/raft/KafkaMetadataLog.scala:
##
@@ -588,9 +588,11 @@ object KafkaMetadataLog extends Logging {
nodeId: Int
): KafkaMetadataLog = {
[
https://issues.apache.org/jira/browse/KAFKA-19271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19271:
Fix Version/s: 4.1.0
> Private interface for injecting test wrappers for KIP-1071 enabled
[
https://issues.apache.org/jira/browse/KAFKA-19392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19392:
---
Fix Version/s: 4.1.0
> `metadata.log.segment.ms` is not applied
> --
[
https://issues.apache.org/jira/browse/KAFKA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957018#comment-17957018
]
vinupreethi93 edited comment on KAFKA-1983 at 6/9/25 3:23 PM:
-
brandboat opened a new pull request, #19933:
URL: https://github.com/apache/kafka/pull/19933
Move AddPartitionsToTxnManagerTest to java
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specifi
brandboat commented on PR #19933:
URL: https://github.com/apache/kafka/pull/19933#issuecomment-2956070664
This is the final piece of
[KAFKA-14895](https://issues.apache.org/jira/browse/KAFKA-14895)
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
[ https://issues.apache.org/jira/browse/KAFKA-1983 ]
vinupreethi93 deleted comment on KAFKA-1983:
--
was (Author: JIRAUSER309961):
Hi If i hard kill another process is coming
> TestEndToEndLatency can be unreliable after hard kill
>
[
https://issues.apache.org/jira/browse/KAFKA-1983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957018#comment-17957018
]
vinupreethi93 commented on KAFKA-1983:
--
Hi, [~junrao]
How to reproduce this issue,
vinupreethi opened a new pull request, #19934:
URL: https://github.com/apache/kafka/pull/19934
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
mingyen066 opened a new pull request, #19936:
URL: https://github.com/apache/kafka/pull/19936
The original props.setProperty(TopicConfig.SEGMENT_MS_CONFIG,
config.logSegmentMillis.toString) in the KafkaMetadataLog constructor was
accidentally removed. Add a test to ensure this property is p
hermanjakobsen opened a new pull request, #19937:
URL: https://github.com/apache/kafka/pull/19937
This PR implements Processor API interfaces for using Anchored punctuation.
As described in
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1146%3A+Anchored+punctuation,
anchored punctua
hermanjakobsen commented on PR #19937:
URL: https://github.com/apache/kafka/pull/19937#issuecomment-2956489125
Would really appreciate input from @mjsax, @ableegoldman or @bbejeck as this
is my first PR to the Kafka project :)
--
This is an automated message from the Apache Git Service.
T
ahuang98 commented on code in PR #19854:
URL: https://github.com/apache/kafka/pull/19854#discussion_r2114996046
##
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##
@@ -2145,7 +2186,19 @@ public void
testObserverSendDiscoveryFetchAfterFetchTimeout(boolean wi
k-raina commented on code in PR #19931:
URL: https://github.com/apache/kafka/pull/19931#discussion_r2136066260
##
docs/design.html:
##
@@ -340,6 +340,18 @@
+The error handling for transactional producer has been standardized which
ensures consistent behavior and clearer er
jolshan commented on code in PR #19931:
URL: https://github.com/apache/kafka/pull/19931#discussion_r2136074359
##
docs/design.html:
##
@@ -340,6 +340,18 @@
+The error handling for transactional producer has been standardized which
ensures consistent behavior and clearer er
FrankYang0529 commented on code in PR #19932:
URL: https://github.com/apache/kafka/pull/19932#discussion_r2135889969
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java:
##
@@ -556,7 +556,7 @@ public String bootstrapServers() {
FrankYang0529 commented on PR #19191:
URL: https://github.com/apache/kafka/pull/19191#issuecomment-2956009055
Created a followup PR: https://github.com/apache/kafka/pull/19932
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
Yunyung commented on PR #19925:
URL: https://github.com/apache/kafka/pull/19925#issuecomment-2955984206
Thanks @FrankYang0529 and @m1a2st for the review. Update according to the
comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-19392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17957016#comment-17957016
]
Chia-Ping Tsai commented on KAFKA-19392:
see https://github.com/apache/kafka/pul
chia7712 commented on code in PR #19932:
URL: https://github.com/apache/kafka/pull/19932#discussion_r2135875059
##
test-common/test-common-runtime/src/main/java/org/apache/kafka/common/test/KafkaClusterTestKit.java:
##
@@ -556,7 +556,7 @@ public String bootstrapServers() {
AndrewJSchofield commented on code in PR #19917:
URL: https://github.com/apache/kafka/pull/19917#discussion_r2135851674
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java:
##
@@ -1135,7 +1134,9 @@ CompletableFuture
revokePartitio
dongnuo123 commented on code in PR #19904:
URL: https://github.com/apache/kafka/pull/19904#discussion_r2135951958
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java:
##
@@ -204,6 +205,11 @@ public class GroupCoordinatorConfig {
apalan60 commented on PR #19920:
URL: https://github.com/apache/kafka/pull/19920#issuecomment-2956146626
I ran a few more test classes that use logging with the command below. They
all passed successfully when executed in the same JVM.
```
/gradlew cleanTest \
-- :connect:ru
apoorvmittal10 commented on code in PR #19928:
URL: https://github.com/apache/kafka/pull/19928#discussion_r2136268973
##
core/src/main/java/kafka/server/share/DelayedShareFetch.java:
##
@@ -808,9 +809,18 @@ private void
releasePartitionLocksAndAddToActionQueue(Set topi
github-actions[bot] commented on PR #15647:
URL: https://github.com/apache/kafka/pull/15647#issuecomment-2957594233
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 leave a comment asking for a
review. If the P
frankvicky merged PR #19911:
URL: https://github.com/apache/kafka/pull/19911
--
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
johnny94 commented on code in PR #19793:
URL: https://github.com/apache/kafka/pull/19793#discussion_r2135206260
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -909,12 +911,33 @@ class ReplicaManager(val config: KafkaConfig,
entriesPerPartition: Map[TopicIdP
frankvicky commented on code in PR #19853:
URL: https://github.com/apache/kafka/pull/19853#discussion_r2135208762
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -407,18 +407,6 @@ public long remoteLogManagerTaskIntervalMs()
[
https://issues.apache.org/jira/browse/KAFKA-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal updated KAFKA-19386:
--
Fix Version/s: 4.1.0
> Incorrect ExpirationReaper thread names from DelayedOperationPurgatory
[
https://issues.apache.org/jira/browse/KAFKA-19386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-19386.
---
Resolution: Fixed
> Incorrect ExpirationReaper thread names from DelayedOperationPurgatory
>
apoorvmittal10 merged PR #19918:
URL: https://github.com/apache/kafka/pull/19918
--
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.
DL1231 commented on code in PR #19926:
URL: https://github.com/apache/kafka/pull/19926#discussion_r2135577426
##
tests/docker/ducker-ak:
##
@@ -431,15 +431,15 @@ attempting to start new ones."
exec 3>&-
for n in $(seq -f %02g 1 ${num_nodes}); do
local node="du
Yunyung commented on code in PR #19926:
URL: https://github.com/apache/kafka/pull/19926#discussion_r2135597580
##
tests/docker/ducker-ak:
##
@@ -431,15 +431,15 @@ attempting to start new ones."
exec 3>&-
for n in $(seq -f %02g 1 ${num_nodes}); do
local node="d
m1a2st commented on code in PR #19924:
URL: https://github.com/apache/kafka/pull/19924#discussion_r2135620371
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -451,20 +451,21 @@ class ReplicaManagerTest {
partition.createLogIfNotExists(isNew = fals
Rancho-7 commented on code in PR #19923:
URL: https://github.com/apache/kafka/pull/19923#discussion_r2135630377
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2702,9 +2703,9 @@ class ReplicaManagerTest {
val replicaManager =
setUpReplicaManager
Rancho-7 commented on PR #19919:
URL: https://github.com/apache/kafka/pull/19919#issuecomment-2955634717
> Could you also update the version of JUnit in NOTICE-binary ?
@frankvicky Thanks for catching this.Updated.
--
This is an automated message from the Apache Git Service.
To resp
1 - 100 of 115 matches
Mail list logo
