[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cameron Redpath updated KAFKA-16277:
Description:
Consider the following scenario:
`topic-1`: 12 partitions
`topic-2`: 12
showuon commented on PR #14744:
URL: https://github.com/apache/kafka/pull/14744#issuecomment-1951789085
Retriggering CI:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-14744/4/
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
showuon commented on PR #15213:
URL: https://github.com/apache/kafka/pull/15213#issuecomment-1951764274
@clolov , there's a compilation error in jdk 8/scala 2.12. Could you help
fix it? Maybe rebasing to the latest trunk could solve it?
--
This is an automated message from the Apache Git
showuon commented on PR #14652:
URL: https://github.com/apache/kafka/pull/14652#issuecomment-1951760048
@hudeqi , are you still interested in completing this PR? There seems to
have some unaddressed comments..=
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16277:
--
Component/s: clients
consumer
> CooperativeStickyAssignor does not spread topics
showuon commented on code in PR #14289:
URL: https://github.com/apache/kafka/pull/14289#discussion_r1493974832
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -1408,6 +1408,16 @@ class ReplicaManager(val config: KafkaConfig,
// progress in such cases
github-actions[bot] commented on PR #14652:
URL: https://github.com/apache/kafka/pull/14652#issuecomment-1951633659
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 #14744:
URL: https://github.com/apache/kafka/pull/14744#issuecomment-1951633449
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
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cameron Redpath updated KAFKA-16277:
Description:
Consider the following scenario:
`topic-1`: 12 partitions
`topic-2`: 12
[
https://issues.apache.org/jira/browse/KAFKA-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cameron Redpath updated KAFKA-16277:
Description:
Consider the following scenario:
`topic-1`: 12 partitions
`topic-2`: 12
Cameron Redpath created KAFKA-16277:
---
Summary: CooperativeStickyAssignor does not spread topics evenly
among consumer group
Key: KAFKA-16277
URL: https://issues.apache.org/jira/browse/KAFKA-16277
appchemist opened a new pull request, #15388:
URL: https://github.com/apache/kafka/pull/15388
While reading the Consumer code, I found that the code and comments did not
match.
I have created a PR to fix these inconsistencies.
### Committer Checklist (excluded from commit message)
ocadaruma commented on code in PR #14289:
URL: https://github.com/apache/kafka/pull/14289#discussion_r1493877586
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -421,6 +446,18 @@ private AbstractIterator
batchIterator(int start) {
ocadaruma commented on code in PR #14289:
URL: https://github.com/apache/kafka/pull/14289#discussion_r1493877586
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -421,6 +446,18 @@ private AbstractIterator
batchIterator(int start) {
ocadaruma commented on code in PR #14289:
URL: https://github.com/apache/kafka/pull/14289#discussion_r1493875931
##
clients/src/main/java/org/apache/kafka/common/record/FileRecords.java:
##
@@ -421,6 +446,18 @@ private AbstractIterator
batchIterator(int start) {
[
https://issues.apache.org/jira/browse/KAFKA-14049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14049:
Fix Version/s: 3.7.0
> Relax Non Null Requirement for KStreamGlobalKTable Left Join
>
[
https://issues.apache.org/jira/browse/KAFKA-15713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818300#comment-17818300
]
Pavel Pozdeev commented on KAFKA-15713:
---
Can I pick this up?
> KRaft support in
AyoubOm commented on code in PR #15361:
URL: https://github.com/apache/kafka/pull/15361#discussion_r1493740130
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/GlobalStateTaskTest.java:
##
@@ -217,21 +215,53 @@ public void
18 matches
Mail list logo
