github-actions[bot] commented on PR #19672:
URL: https://github.com/apache/kafka/pull/19672#issuecomment-3194104739
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
github-actions[bot] closed pull request #19041: KAFKA-18873: Fixed incorrect
error message when exceeds 5 for transactional producers
URL: https://github.com/apache/kafka/pull/19041
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
github-actions[bot] commented on PR #19041:
URL: https://github.com/apache/kafka/pull/19041#issuecomment-3194104722
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
github-actions[bot] commented on PR #19455:
URL: https://github.com/apache/kafka/pull/19455#issuecomment-3194099954
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 #19955:
URL: https://github.com/apache/kafka/pull/19955#issuecomment-3194099887
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 #19236:
URL: https://github.com/apache/kafka/pull/19236#issuecomment-3194099986
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 #20300:
URL: https://github.com/apache/kafka/pull/20300#issuecomment-3194099798
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 #20307:
URL: https://github.com/apache/kafka/pull/20307#issuecomment-3194099788
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 #20330:
URL: https://github.com/apache/kafka/pull/20330#issuecomment-3194099772
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 #20331:
URL: https://github.com/apache/kafka/pull/20331#issuecomment-3194099761
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 opened a new pull request, #20363:
URL: https://github.com/apache/kafka/pull/20363
We create—and wait on—PollEvent in Consumer.poll() to ensure we wait for
reconciliation and/or auto-commit. However, reconciliation is relatively rare,
and auto-commit only happens every N seconds, s
k-apol commented on code in PR #20326:
URL: https://github.com/apache/kafka/pull/20326#discussion_r2280644221
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##
@@ -461,120 +466,119 @@ public Set makeReady(final Map topics) {
k-apol commented on code in PR #20326:
URL: https://github.com/apache/kafka/pull/20326#discussion_r2280626341
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##
@@ -461,120 +466,119 @@ public Set makeReady(final Map topics) {
k-apol commented on code in PR #20326:
URL: https://github.com/apache/kafka/pull/20326#discussion_r2280626121
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##
@@ -461,120 +466,119 @@ public Set makeReady(final Map topics) {
k-apol commented on code in PR #20326:
URL: https://github.com/apache/kafka/pull/20326#discussion_r2280623483
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##
@@ -461,120 +466,119 @@ public Set makeReady(final Map topics) {
k-apol commented on code in PR #20326:
URL: https://github.com/apache/kafka/pull/20326#discussion_r2280623447
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java:
##
@@ -113,7 +113,7 @@ public InternalTopicManager(final Time time,
[
https://issues.apache.org/jira/browse/KAFKA-19384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19384.
Fix Version/s: 4.2.0
Resolution: Fixed
> The passing of BrokerRegistrationRequestTe
chia7712 merged PR #20338:
URL: https://github.com/apache/kafka/pull/20338
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
[
https://issues.apache.org/jira/browse/KAFKA-19611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19611:
---
Fix Version/s: 4.2.0
> Enable ProducerPerformance to abort transaction randomly
> --
chickenchickenlove opened a new pull request, #20362:
URL: https://github.com/apache/kafka/pull/20362
### Background
There is race condition in `ConsumerNetworkThread` for `Kafka Streams`.
So it make
`HandlingSourceTopicDeletionIntegrationTest#shouldThrowErrorAfterSourceTopicDeleted`
shashankhs11 commented on code in PR #20329:
URL: https://github.com/apache/kafka/pull/20329#discussion_r2280445817
##
docs/streams/developer-guide/config-streams.html:
##
@@ -492,54 +491,60 @@ num.standby.replicas-1
- retry.backoff.ms
+ repartition
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19430:
External issue URL: https://issues.apache.org/jira/browse/KAFKA-19613
> Don't fail on Reco
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19430:
External issue URL: (was:
https://issues.apache.org/jira/browse/KAFKA-19613)
> Don't fa
[
https://issues.apache.org/jira/browse/KAFKA-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19613:
Description:
As part of analysis of KAFKA-19430 , we decided it would be useful to expose
Uladzislau Blok created KAFKA-19613:
---
Summary: Expose consumer fail root case
Key: KAFKA-19613
URL: https://issues.apache.org/jira/browse/KAFKA-19613
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-19430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18014279#comment-18014279
]
Uladzislau Blok commented on KAFKA-19430:
-
Good Morning.
I'll start working on
Sauhardstark commented on code in PR #18097:
URL: https://github.com/apache/kafka/pull/18097#discussion_r2280391678
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -157,6 +158,7 @@
*/
public class RemoteLogManager implements Closeable, AsyncOffsetReader {
apalan60 commented on code in PR #20338:
URL: https://github.com/apache/kafka/pull/20338#discussion_r2280382821
##
server/src/test/java/org/apache/kafka/server/BrokerRegistrationRequestTest.java:
##
@@ -0,0 +1,246 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
chia7712 commented on code in PR #20199:
URL: https://github.com/apache/kafka/pull/20199#discussion_r2280366590
##
server/src/test/java/org/apache/kafka/server/EligibleLeaderReplicasIntegrationTest.java:
##
@@ -0,0 +1,384 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
AndrewJSchofield opened a new pull request, #20361:
URL: https://github.com/apache/kafka/pull/20361
This implements KIP-1147 for kafka-producer-perf-test.sh.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
chia7712 commented on code in PR #20338:
URL: https://github.com/apache/kafka/pull/20338#discussion_r2280340833
##
server/src/test/java/org/apache/kafka/server/BrokerRegistrationRequestTest.java:
##
@@ -0,0 +1,246 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/KAFKA-19611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18014262#comment-18014262
]
Andrew Schofield commented on KAFKA-19611:
--
Very nice. Of course, this will hav
chia7712 commented on code in PR #20349:
URL: https://github.com/apache/kafka/pull/20349#discussion_r2280334745
##
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java:
##
@@ -222,16 +222,19 @@ public static void main(String[] args) throws Exception {
pjl1070048431 opened a new pull request, #20360:
URL: https://github.com/apache/kafka/pull/20360
Currently, the following validation checks are performed twice for each
partition placement:
throwInvalidReplicationFactorIfNonPositive()
throwInvalidReplicationFactorIfTooFewBrokers()
Jialun Peng created KAFKA-19612:
---
Summary: Remove Redundant Validation in StripedReplicaPlacer
Key: KAFKA-19612
URL: https://issues.apache.org/jira/browse/KAFKA-19612
Project: Kafka
Issue Type:
35 matches
Mail list logo
