rayokota commented on code in PR #13425:
URL: https://github.com/apache/kafka/pull/13425#discussion_r1148316785
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java:
##
@@ -306,10 +297,10 @@ ConsumerRecord parseRecord(TopicPartition partition,
rayokota commented on code in PR #13425:
URL: https://github.com/apache/kafka/pull/13425#discussion_r1148316785
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java:
##
@@ -306,10 +297,10 @@ ConsumerRecord parseRecord(TopicPartition partition,
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704864#comment-17704864
]
Philip Nee edited comment on KAFKA-14639 at 3/25/23 5:26 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704864#comment-17704864
]
Philip Nee edited comment on KAFKA-14639 at 3/25/23 3:54 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704864#comment-17704864
]
Philip Nee edited comment on KAFKA-14639 at 3/25/23 3:50 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704864#comment-17704864
]
Philip Nee commented on KAFKA-14639:
Two issues I see...
# why did consumer-4 revok
[
https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704843#comment-17704843
]
tony mancill commented on KAFKA-14016:
--
Yes - thank you for the redirect [~pnee] !
jeffkbkim commented on code in PR #13443:
URL: https://github.com/apache/kafka/pull/13443#discussion_r1146805063
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignmentMemberSpec.java:
##
@@ -37,29 +39,28 @@ public class AssignmentMemberSpec {
[
https://issues.apache.org/jira/browse/KAFKA-14365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-14365.
---
Fix Version/s: 3.5.0
Reviewer: Guozhang Wang
Resolution: Fixed
> Extract common logi
kirktrue closed pull request #13152: KAFKA-14365 refactor fetcher, take 4
URL: https://github.com/apache/kafka/pull/13152
--
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 uns
kirktrue closed pull request #13293: KAFKA-14365: Extract common logic from
Fetcher into FetcherUtils
URL: https://github.com/apache/kafka/pull/13293
--
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
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1148140557
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -113,15 +112,45 @@ private void maybeAutoCommit(final long curre
guozhangwang commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1148127234
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -113,15 +112,45 @@ private void maybeAutoCommit(final long cu
[
https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704833#comment-17704833
]
Philip Nee commented on KAFKA-14016:
Hey [~showuon] - It doesn't seem like the issue
CalvinConfluent commented on code in PR #13408:
URL: https://github.com/apache/kafka/pull/13408#discussion_r1148108087
##
metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java:
##
@@ -449,7 +450,8 @@ public void testBalancePartitionLeaders() throws Throwab
Guozhang Wang created KAFKA-14847:
-
Summary: Separate the callers of commitAllTasks v.s. commitTasks
for EOS(-v2) and ALOS
Key: KAFKA-14847
URL: https://issues.apache.org/jira/browse/KAFKA-14847
Proje
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1148084290
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1148082243
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -481,6 +493,11 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1148081688
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+
guozhangwang merged PR #13425:
URL: https://github.com/apache/kafka/pull/13425
--
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.ap
guozhangwang commented on PR #13425:
URL: https://github.com/apache/kafka/pull/13425#issuecomment-1483427964
LGTM, merged to trunk.
--
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 co
guozhangwang commented on PR #13425:
URL: https://github.com/apache/kafka/pull/13425#issuecomment-1483427747
I've checked the failed tests, which are irrelevant.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-14639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee reassigned KAFKA-14639:
--
Assignee: Philip Nee
> Kafka CooperativeStickyAssignor revokes/assigns partition in one rebal
guozhangwang commented on code in PR #13425:
URL: https://github.com/apache/kafka/pull/13425#discussion_r1148071896
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java:
##
@@ -0,0 +1,791 @@
+/*
+ * Licensed to the Apache Software Foundation (A
[
https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704819#comment-17704819
]
Philip Nee commented on KAFKA-14016:
Actually [~tmancill] - I think this is similar
artemlivshits commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1148060963
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -0,0 +1,173 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or m
junrao commented on code in PR #13408:
URL: https://github.com/apache/kafka/pull/13408#discussion_r1148021906
##
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java:
##
@@ -596,6 +596,11 @@ public void checkBrokerEpoch(int brokerId, long
brokerEpoch) {
[
https://issues.apache.org/jira/browse/KAFKA-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704805#comment-17704805
]
Philip Nee commented on KAFKA-14016:
Hey [~tmancill] - Thanks for chipping in, I thi
guozhangwang commented on code in PR #13425:
URL: https://github.com/apache/kafka/pull/13425#discussion_r1148026726
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -172,606 +69,41 @@ public boolean hasAvailableFetches() {
* @return
vcrfxia opened a new pull request, #13449:
URL: https://github.com/apache/kafka/pull/13449
(This PR is stacked on https://github.com/apache/kafka/pull/13442. The first
commit does not need to be reviewed separately.)
This PR adds an integration test for the manual upgrade scenario to
cmccabe merged PR #13438:
URL: https://github.com/apache/kafka/pull/13438
--
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.
mumrah commented on code in PR #13438:
URL: https://github.com/apache/kafka/pull/13438#discussion_r1147915745
##
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
mumrah commented on code in PR #13438:
URL: https://github.com/apache/kafka/pull/13438#discussion_r1147915381
##
core/src/main/scala/kafka/server/ControllerServer.scala:
##
@@ -366,6 +376,8 @@ class ControllerServer(
// Ensure that we're not the Raft leader prior to shutt
cmccabe commented on code in PR #13368:
URL: https://github.com/apache/kafka/pull/13368#discussion_r1147904638
##
core/src/main/scala/kafka/zk/ZkMigrationClient.scala:
##
@@ -211,12 +214,38 @@ class ZkMigrationClient(zkClient: KafkaZkClient) extends
MigrationClient with Lo
cmccabe commented on PR #13368:
URL: https://github.com/apache/kafka/pull/13368#issuecomment-1483198582
It looks good overall. I filed a separate issue to handle the batching thing.
I didn't completely understand why we couldn't have a
`ZkMigrationClientTest` for this, can you explain
[
https://issues.apache.org/jira/browse/KAFKA-14436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704734#comment-17704734
]
Colin McCabe commented on KAFKA-14436:
--
We decided to preserve and continue to use
cmccabe merged PR #13448:
URL: https://github.com/apache/kafka/pull/13448
--
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-14436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14436.
--
Fix Version/s: 3.4.0
Resolution: Won't Fix
> Initialize KRaft with arbitrary epoch
> --
shayelkin opened a new pull request, #13448:
URL: https://github.com/apache/kafka/pull/13448
Similar to https://github.com/apache/kafka/pull/13439:
ddd652c standardized on "isolated" as the name for all the isolated modes,
and renamed remote_controller_quorum to
kafkatest.services.
cmccabe commented on code in PR #13368:
URL: https://github.com/apache/kafka/pull/13368#discussion_r1147881142
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -597,6 +629,13 @@ public void run() throws Exception {
compl
Colin McCabe created KAFKA-14846:
Summary: Fix overly large record batches in ZkMigrationClient
Key: KAFKA-14846
URL: https://issues.apache.org/jira/browse/KAFKA-14846
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-14493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14493.
--
Fix Version/s: 3.4.0
Resolution: Fixed
> Zk to KRaft migration state machine in KRaft c
[
https://issues.apache.org/jira/browse/KAFKA-14458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704723#comment-17704723
]
Colin McCabe commented on KAFKA-14458:
--
[~showuon]: that's right. I'll close this.
[
https://issues.apache.org/jira/browse/KAFKA-14493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704724#comment-17704724
]
Colin McCabe commented on KAFKA-14493:
--
[~showuon]: yes, this was completed in 3.4.
[
https://issues.apache.org/jira/browse/KAFKA-14458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14458.
--
Fix Version/s: 3.4.0
Resolution: Fixed
> RPC Handler to ZkBrokers from KRaft Controller
[
https://issues.apache.org/jira/browse/KAFKA-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14446.
--
Fix Version/s: 3.4.0
Resolution: Fixed
> API forwarding support in ZkBrokers
>
[
https://issues.apache.org/jira/browse/KAFKA-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704721#comment-17704721
]
Colin McCabe commented on KAFKA-14446:
--
[~showuon], yes, this was already completed
[
https://issues.apache.org/jira/browse/KAFKA-14446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-14446:
-
Summary: API forwarding support in ZkBrokers during KRaft migration (was:
API forwarding suppor
[
https://issues.apache.org/jira/browse/KAFKA-14447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-14447.
--
Fix Version/s: 3.4.0
(was: 3.4.1)
Resolution: Fixed
> Controlled
C0urante commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1147779547
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1133,6 +1139,105 @@ public void setTargetState(String connName, TargetState
stat
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147857120
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = requ
mimaison commented on code in PR #13325:
URL: https://github.com/apache/kafka/pull/13325#discussion_r1147836371
##
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##
@@ -2547,9 +2547,10 @@ private void acquireAndEnsureOpen() {
* @throws Concurre
jolshan commented on PR #13447:
URL: https://github.com/apache/kafka/pull/13447#issuecomment-1483108202
alternative to:
https://github.com/apache/kafka/pull/12541 and
https://github.com/apache/kafka/pull/12378
--
This is an automated message from the Apache Git Service.
To respond to t
jolshan opened a new pull request, #13447:
URL: https://github.com/apache/kafka/pull/13447
On startup, we go from topic id null to defined. We will lower the log level
so folks with info level logs are not spammed.
### Committer Checklist (excluded from commit message)
- [ ] Verif
C0urante commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1147773784
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1133,6 +1139,105 @@ public void setTargetState(String connName, TargetState
stat
junrao commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147813111
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
[
https://issues.apache.org/jira/browse/KAFKA-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez reassigned KAFKA-14845:
-
Assignee: Alexandre Dupriez
> Broker ZNode creation can fail due to a session I
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147804661
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = requ
junrao commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147794328
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147789029
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -481,6 +493,11 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
jolshan commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147787658
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = requ
viktorsomogyi commented on PR #13441:
URL: https://github.com/apache/kafka/pull/13441#issuecomment-1483048870
retest this please
--
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 comme
viktorsomogyi commented on PR #13441:
URL: https://github.com/apache/kafka/pull/13441#issuecomment-1483025821
retest
--
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 unsu
mimaison commented on code in PR #13326:
URL: https://github.com/apache/kafka/pull/13326#discussion_r1147752608
##
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala:
##
@@ -1167,6 +1168,35 @@ class DynamicBrokerReconfigurationTest extends
Quoru
wcarlson5 merged PR #13382:
URL: https://github.com/apache/kafka/pull/13382
--
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.apach
[
https://issues.apache.org/jira/browse/KAFKA-14800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison reassigned KAFKA-14800:
--
Assignee: Juan Ramos
> Upgrade snappy-java Version to 1.1.9.1
> -
mimaison merged PR #13385:
URL: https://github.com/apache/kafka/pull/13385
--
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
mimaison merged PR #13428:
URL: https://github.com/apache/kafka/pull/13428
--
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-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14845:
--
Description:
Our production environment faced a use case where registration of a broke
[
https://issues.apache.org/jira/browse/KAFKA-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14845:
--
Description:
Our production environment faced a use case where registration of a broke
[
https://issues.apache.org/jira/browse/KAFKA-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14845:
--
Attachment: broker-registration.drawio.png
> Broker ZNode creation can fail due to a s
[
https://issues.apache.org/jira/browse/KAFKA-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14845:
--
Attachment: (was: broker-registration.drawio)
> Broker ZNode creation can fail due
junrao commented on code in PR #13391:
URL: https://github.com/apache/kafka/pull/13391#discussion_r1147689005
##
core/src/main/scala/kafka/network/RequestChannel.scala:
##
@@ -483,14 +493,10 @@ class RequestChannel(val queueSize: Int,
def sendShutdownRequest(): Unit = reque
mimaison commented on PR #13257:
URL: https://github.com/apache/kafka/pull/13257#issuecomment-1482926158
ping @mumrah
--
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 un
[
https://issues.apache.org/jira/browse/KAFKA-14751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704647#comment-17704647
]
ASF GitHub Bot commented on KAFKA-14751:
mimaison merged PR #494:
URL: https://g
[
https://issues.apache.org/jira/browse/KAFKA-14845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexandre Dupriez updated KAFKA-14845:
--
Description:
Our production environment faced a use case where registration of a broke
[
https://issues.apache.org/jira/browse/KAFKA-14751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-14751.
Resolution: Fixed
> Official website CONTACT page IRC channel link change
> -
hudeqi commented on PR #13446:
URL: https://github.com/apache/kafka/pull/13446#issuecomment-1482923618
--
This is an automated message from the Apache Git Service.
To respond to
Alexandre Dupriez created KAFKA-14845:
-
Summary: Broker ZNode creation can fail due to a session ID
unknown to the broker
Key: KAFKA-14845
URL: https://issues.apache.org/jira/browse/KAFKA-14845
Pr
mimaison commented on PR #13417:
URL: https://github.com/apache/kafka/pull/13417#issuecomment-1482901060
Yes moving some of these tools is not trivial.
In this case:
- `kafka.tools.TerseFailure` can be replaced with
`org.apache.kafka.tools.TerseException`
- For `KafkaConfig` I don't
mimaison commented on PR #13078:
URL: https://github.com/apache/kafka/pull/13078#issuecomment-1482811940
Is this KIP complete? This has been merged but the associated
[JIRA](https://issues.apache.org/jira/browse/KAFKA-13999) is not marked as
resolved.
--
This is an automated message from
chia7712 commented on PR #13393:
URL: https://github.com/apache/kafka/pull/13393#issuecomment-1482717404
```
[2023-03-23T20:27:39.266Z] Gradle Test Run :core:integrationTest > Gradle
Test Executor 182 > PlaintextAdminIntegrationTest >
testReplicaCanFetchFromLogStartOffsetAfterDeleteR
[
https://issues.apache.org/jira/browse/KAFKA-13922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704565#comment-17704565
]
Andras Katona commented on KAFKA-13922:
---
I have a jacoco related PR, which i want
[
https://issues.apache.org/jira/browse/KAFKA-13922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andras Katona reassigned KAFKA-13922:
-
Assignee: Andras Katona
> Unable to generate coverage reports for the whole project
> -
[
https://issues.apache.org/jira/browse/KAFKA-14823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14823:
---
Labels: nee (was: )
> Clean up ConfigProvider API
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14823:
---
Labels: (was: nee)
> Clean up ConfigProvider API
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-14822:
---
Labels: need-kip (was: )
> Allow restricting File and Directory ConfigProviders to specific
[
https://issues.apache.org/jira/browse/KAFKA-14843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14843:
-
Assignee: Jorge Esteban Quilcate Otoya
> Connector plugins config endpoint does not include Com
yashmayya commented on code in PR #13434:
URL: https://github.com/apache/kafka/pull/13434#discussion_r1147332613
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1133,6 +1139,106 @@ public void setTargetState(String connName, TargetState
sta
dengziming commented on code in PR #13432:
URL: https://github.com/apache/kafka/pull/13432#discussion_r1147319995
##
clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiHandler.java:
##
@@ -70,6 +71,22 @@
*/
ApiResult handleResponse(Node broker, Set
Yash Mayya created KAFKA-14844:
--
Summary: Kafka Connect's OffsetBackingStore interface should
handle (de)serialization and connector namespacing
Key: KAFKA-14844
URL: https://issues.apache.org/jira/browse/KAFKA-14844
vamossagar12 commented on PR #13361:
URL: https://github.com/apache/kafka/pull/13361#issuecomment-1482497859
> > I don't think that we should add retries when we already know that the
exceptions that would be caught here are non-retriable. Additionally, it may be
unsafe or incorrect to retr
rohits64 commented on PR #13361:
URL: https://github.com/apache/kafka/pull/13361#issuecomment-1482493926
Thanks @mukkachaitanya, @gharris1727 and @vamossagar12 for looking into
this. As pointed out it should be fair to fail instead of retrying. As there
might be unexpected behaviour with un
vamossagar12 commented on PR #13361:
URL: https://github.com/apache/kafka/pull/13361#issuecomment-1482487641
Thanks for the PR @rohits64 . I would agree with @gharris1727 and
@mukkachaitanya in this case that we shouldn't add the overhead of retries in
this case. Also, as pointed out, the o
Stephan14 closed pull request #13435: KAFKA-14832：fix thread unsafe for
GroupMetadata when persisting metadata
URL: https://github.com/apache/kafka/pull/13435
--
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
Stephan14 commented on PR #13435:
URL: https://github.com/apache/kafka/pull/13435#issuecomment-1482444228
Oh, you are right!
--
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.
hudeqi opened a new pull request, #13446:
URL: https://github.com/apache/kafka/pull/13446
In practice, I found that when I configure a mirror checkpoint connector,
because the source cluster has a large number of group or the number of group
under a topic changes frequently, the connector w
yashmayya commented on code in PR #13445:
URL: https://github.com/apache/kafka/pull/13445#discussion_r1147220918
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -836,10 +836,19 @@ public List connectorPluginConfig(String
pluginName)
yashmayya commented on code in PR #13375:
URL: https://github.com/apache/kafka/pull/13375#discussion_r1147214226
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectWorkerIntegrationTest.java:
##
@@ -195,7 +197,22 @@ public void testRestartFailedTask() t
yashmayya commented on code in PR #13375:
URL: https://github.com/apache/kafka/pull/13375#discussion_r1147210852
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java:
##
@@ -656,6 +567,19 @@ public KafkaProducer
createProducer(Map pr
1 - 100 of 103 matches
Mail list logo
