shirenchuang opened a new pull request #11453:
URL: https://github.com/apache/kafka/pull/11453
fix KAFKA-13226
*More detailed description of your change,
if not sort the brokerMetaData
Partition expansion may cause uneven distribution
*Summary of testing strategy (includi
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-13421:
-
Description:
ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBi
Colin McCabe created KAFKA-13421:
Summary: Fix
ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Key: KAFKA-13421
URL: https://issues.apache.org/jira/browse/KAFKA-13421
cmccabe commented on pull request #11440:
URL: https://github.com/apache/kafka/pull/11440#issuecomment-955129597
Here is an example of halt() being called from a junit test:
```
java.lang.RuntimeException: TRIED TO CALL HALT
at org.apache.kafka.common.utils.Exit$1.execute(Exit.j
bdesert commented on a change in pull request #11401:
URL: https://github.com/apache/kafka/pull/11401#discussion_r739570175
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java
##
@@ -152,6 +152,44 @@ public void testConfigP
[
https://issues.apache.org/jira/browse/KAFKA-13351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17436205#comment-17436205
]
Florin Akermann commented on KAFKA-13351:
-
Hi, I would like to pick this up.
>
bdesert commented on a change in pull request #11401:
URL: https://github.com/apache/kafka/pull/11401#discussion_r739570175
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java
##
@@ -152,6 +152,44 @@ public void testConfigP
hachikuji opened a new pull request #11452:
URL: https://github.com/apache/kafka/pull/11452
If the user's `initTransactions` call times out, the user is expected to
retry. However, the producer will continue retrying the `InitProducerId`
request in the background. If it happens to return b
OmniaGM commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r739499675
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -183,12 +187,18 @@ public MirrorClientConfig clie
OmniaGM commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r739499675
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -183,12 +187,18 @@ public MirrorClientConfig clie
OmniaGM commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r737592730
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -183,12 +187,18 @@ public MirrorClientConfig clie
OmniaGM commented on a change in pull request #11431:
URL: https://github.com/apache/kafka/pull/11431#discussion_r739494732
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
##
@@ -183,12 +187,18 @@ public MirrorClientConfig clie
hachikuji commented on pull request #11449:
URL: https://github.com/apache/kafka/pull/11449#issuecomment-954935502
It's worth noting that we already have the WARN log here when a connection
cannot be established:
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/k
hachikuji commented on a change in pull request #11449:
URL: https://github.com/apache/kafka/pull/11449#discussion_r739414003
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -320,21 +320,17 @@ public void disconnect(String nodeId) {
junrao commented on a change in pull request #11443:
URL: https://github.com/apache/kafka/pull/11443#discussion_r739409165
##
File path:
clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java
##
@@ -216,7 +218,14 @@ SaslClient createS
mimaison commented on a change in pull request #11401:
URL: https://github.com/apache/kafka/pull/11401#discussion_r739322252
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java
##
@@ -152,6 +152,44 @@ public void testConfig
dengziming commented on a change in pull request #11450:
URL: https://github.com/apache/kafka/pull/11450#discussion_r739315725
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/storage/FileOffsetBackingStoreTest.java
##
@@ -77,21 +74,17 @@ public void teardo
[
https://issues.apache.org/jira/browse/KAFKA-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shylaja kokoori reassigned KAFKA-13418:
---
Assignee: shylaja kokoori
> Brokers disconnect intermittently with TLS1.3
> ---
mimaison commented on a change in pull request #11137:
URL: https://github.com/apache/kafka/pull/11137#discussion_r739243762
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/AbstractHerderTest.java
##
@@ -135,90 +133,75 @@
private final int gen
dengziming commented on a change in pull request #10830:
URL: https://github.com/apache/kafka/pull/10830#discussion_r739234189
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java
##
@@ -94,6 +94,15 @@ public static int jsonNodeToUnsignedShort(
Luke Chen created KAFKA-13420:
-
Summary: consumer protocol should include "generation" field for
assignor to distinguish between new/old OwnedPartitions
Key: KAFKA-13420
URL: https://issues.apache.org/jira/browse/KAFK
showuon commented on pull request #11451:
URL: https://github.com/apache/kafka/pull/11451#issuecomment-954723413
@ableegoldman @guozhangwang @dajac @hachikuji , do you think this change
make sense? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the mes
[
https://issues.apache.org/jira/browse/KAFKA-13419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13419:
--
Summary: sync group failed with rebalanceInProgress error might cause
out-of-date ownedPartition in Co
showuon commented on pull request #11439:
URL: https://github.com/apache/kafka/pull/11439#issuecomment-954708858
@ableegoldman , it's good to review now. 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
showuon opened a new pull request #11451:
URL: https://github.com/apache/kafka/pull/11451
`resetStateAndRejoin` when `REBALANCE_IN_PROGRESS` error in sync group, to
avoid out-of-date `ownedPartition`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and im
[
https://issues.apache.org/jira/browse/KAFKA-13419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13419:
--
Description:
In KAFKA-13406, we found there's user got stuck when in rebalancing with
cooperative sti
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-954686762
> @vvcephei @cadonna @mjsax @guozhangwang anyone have any thoughts on this?
hi all... it would be great if we can have some decision on this one.
Whenever you get the
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739172245
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -601,6 +608,10 @@ boolean runLoop() {
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739171689
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -385,7 +385,7 @@ public synchron
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739171078
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -721,6 +732,10 @@ public void resizeCache(f
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739166999
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -793,6 +809,10 @@ void runOnce() {
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739158573
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -736,11 +734,8 @@ public boolean process(fina
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739158573
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -736,11 +734,8 @@ public boolean process(fina
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r739157355
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1057,6 +1057,17 @@ void addRecordsToTasks(f
vamossagar12 commented on a change in pull request #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r739152945
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -292,12 +327,20 @@ public void handleAssignm
amuraru closed pull request #1407:
URL: https://github.com/apache/kafka/pull/1407
--
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...
mnegodaev commented on pull request #11442:
URL: https://github.com/apache/kafka/pull/11442#issuecomment-954654651
@rhauch could you please review my PR?
--
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
[
https://issues.apache.org/jira/browse/KAFKA-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Michael Negodaev reassigned KAFKA-7883:
---
Assignee: Michael Negodaev
> Add schema.namespace support to SetSchemaMetadata SMT i
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435884#comment-17435884
]
Dongjin Lee commented on KAFKA-7632:
[~benedikt] Oh yes, the issue description is obs
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-7632:
---
Description:
The compression level for ZSTD is currently set to use the default level (3),
which is
dajac commented on a change in pull request #11449:
URL: https://github.com/apache/kafka/pull/11449#discussion_r739097403
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -320,21 +320,17 @@ public void disconnect(String nodeId) {
dajac commented on a change in pull request #11448:
URL: https://github.com/apache/kafka/pull/11448#discussion_r739089348
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1341,7 +1341,7 @@ object KafkaConfig {
fromProps(props, doLog)
}
- def ap
mimaison opened a new pull request #11450:
URL: https://github.com/apache/kafka/pull/11450
I've skipped the following classes as they use powermock to stub/access
private and static fields/methods:
- KafkaConfigBackingStoreTest
- KafkaOffsetBackingStoreTest
Those will require s
[
https://issues.apache.org/jira/browse/KAFKA-13405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435853#comment-17435853
]
Daniel O'Halloran commented on KAFKA-13405:
---
Thanks for you your reply.
So we
Luke Chen created KAFKA-13419:
-
Summary: sync group failed with retriable error might cause
out-of-date ownedPartition in Cooperative protocol
Key: KAFKA-13419
URL: https://issues.apache.org/jira/browse/KAFKA-13419
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435809#comment-17435809
]
Benedikt Linse edited comment on KAFKA-7632 at 10/29/21, 7:08 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-7632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435809#comment-17435809
]
Benedikt Linse commented on KAFKA-7632:
---
The description of this Jira says "as a br
47 matches
Mail list logo
