showuon commented on code in PR #13327:
URL: https://github.com/apache/kafka/pull/13327#discussion_r1124118829
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -678,7 +678,7 @@ object KafkaConfig {
"start from " + MaxReservedBrokerIdProp + " + 1."
val
[
https://issues.apache.org/jira/browse/KAFKA-13421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696010#comment-17696010
]
Philip Nee commented on KAFKA-13421:
I think the original issue
philipnee commented on PR #12038:
URL: https://github.com/apache/kafka/pull/12038#issuecomment-1452987508
I wonder if it is because of the heartbeat interval. Here we are starting 5
consumers, each polling for 50ms = 250ms. The heartbeat interval is 1000ms.
After bumping it to 10s, it
philipnee opened a new pull request, #12038:
URL: https://github.com/apache/kafka/pull/12038
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
ijuma commented on code in PR #13304:
URL: https://github.com/apache/kafka/pull/13304#discussion_r1124016717
##
storage/src/main/java/org/apache/kafka/storage/internals/log/FetchDataInfo.java:
##
@@ -44,6 +45,28 @@ public FetchDataInfo(LogOffsetMetadata fetchOffsetMetadata,
[
https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695999#comment-17695999
]
Ganesh Sahu commented on KAFKA-9234:
Sure, Thank you. I just joined the community this week. I
satishd commented on code in PR #13304:
URL: https://github.com/apache/kafka/pull/13304#discussion_r1124009466
##
storage/src/main/java/org/apache/kafka/storage/internals/log/FetchDataInfo.java:
##
@@ -44,6 +45,28 @@ public FetchDataInfo(LogOffsetMetadata fetchOffsetMetadata,
[
https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695962#comment-17695962
]
fujian edited comment on KAFKA-14768 at 3/3/23 2:47 AM:
Hi [~showuon]
I
mjsax commented on code in PR #13274:
URL: https://github.com/apache/kafka/pull/13274#discussion_r1123970487
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java:
##
@@ -48,20 +55,30 @@ public StoreBuilder>
materialize() {
mjsax commented on code in PR #13274:
URL: https://github.com/apache/kafka/pull/13274#discussion_r1123965019
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KeyValueStoreMaterializer.java:
##
@@ -48,20 +55,30 @@ public StoreBuilder>
materialize() {
[
https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695962#comment-17695962
]
fujian commented on KAFKA-14768:
Hi [~showuon]
I checked the KIP and related JIRA. I think the KIP is
mjsax commented on code in PR #13300:
URL: https://github.com/apache/kafka/pull/13300#discussion_r1123947731
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java:
##
@@ -986,6 +987,11 @@ private void prepareChangelogs(final
Set
[
https://issues.apache.org/jira/browse/KAFKA-14768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695956#comment-17695956
]
fujian commented on KAFKA-14768:
Hi [~showuon]
Thanks for your feedback.
For 1, send one "warm up"
gharris1727 opened a new pull request, #13334:
URL: https://github.com/apache/kafka/pull/13334
The logic for decomposing a `plugin.path` list into the component
single-plugin locations is nontrivial, and currently implemented by the
DelegatingClassLoader. Decoupling this logic from the
guozhangwang commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1452793608
SmokeTestDriverIntegrationTest did not fail in
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13318/11, triggering
again.
If that run still did not fail
kirktrue commented on PR #13301:
URL: https://github.com/apache/kafka/pull/13301#issuecomment-1452775886
@guozhangwang wrote:
> A meta comment is that for the extracted classes, I think we should add
unit test coverages for them (hopefully most of them are already in the
gharris1727 opened a new pull request, #1:
URL: https://github.com/apache/kafka/pull/1
This class has a circular classloading dependency that causes an NPE if
TestPlugins.TestPlugin is loaded before TestPlugins. This was introduced in
#13182 but does not impact the build because
[
https://issues.apache.org/jira/browse/KAFKA-14748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695945#comment-17695945
]
Matthias J. Sax commented on KAFKA-14748:
-
{quote}But for table-table FK-joins, today the former
kirktrue commented on code in PR #12813:
URL: https://github.com/apache/kafka/pull/12813#discussion_r1123911988
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -641,7 +643,7 @@ private void completeBatch(ProducerBatch batch,
cmccabe opened a new pull request, #13332:
URL: https://github.com/apache/kafka/pull/13332
This PR allows us to dynamically reconfigure the KRaft controller by setting
either a cluster configuration (that is, a configuration that applies to all
resource of type BROKER), or by configuring a
[
https://issues.apache.org/jira/browse/KAFKA-14057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe reassigned KAFKA-14057:
Assignee: Colin McCabe
> Support dynamic reconfiguration in KRaft remote controllers
>
vcrfxia commented on code in PR #13292:
URL: https://github.com/apache/kafka/pull/13292#discussion_r1116012004
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/UnwindowedChangelogTopicConfig.java:
##
@@ -25,7 +25,7 @@
/**
*
mjsax merged PR #13264:
URL: https://github.com/apache/kafka/pull/13264
--
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:
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123774975
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1303,11 +1305,13 @@ public void
cmccabe opened a new pull request, #13331:
URL: https://github.com/apache/kafka/pull/13331
This PR has two fixes for fault handling. One makes fault handling more
strict on the controller; the other makes it a bit less strict on the
(ZK-based) broker.
In ControllerServer, invoke a
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123767340
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1328,7 +1328,7 @@ Priority priority() {
@Override
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123765294
##
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java:
##
@@ -118,11 +123,78 @@ public AddPartitionsToTxnRequestData data() {
philipnee commented on code in PR #13330:
URL: https://github.com/apache/kafka/pull/13330#discussion_r1123760146
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ProtocolRequestManager.java:
##
@@ -0,0 +1,96 @@
+package
philipnee commented on code in PR #13330:
URL: https://github.com/apache/kafka/pull/13330#discussion_r1123759741
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ProtocolRequestManager.java:
##
@@ -0,0 +1,96 @@
+package
philipnee opened a new pull request, #13330:
URL: https://github.com/apache/kafka/pull/13330
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
guozhangwang commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1452549269
`SmokeTestDriverIntegrationTest` did not fail in
`https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13318/2`,
triggering again.
--
This is an automated message from the
twmb commented on PR #12990:
URL: https://github.com/apache/kafka/pull/12990#issuecomment-1452523214
:wave: hi, seeing this after it's merged! Is the intent to create a new PR
for making the sticky assignor rack aware? I see in the original PR #12914 that
both range and sticky were
gharris1727 commented on PR #13313:
URL: https://github.com/apache/kafka/pull/13313#issuecomment-1452503148
This refactor first landed in #432 and then the current dependency graph was
set by #512
--
This is an automated message from the Apache Git Service.
To respond to the message,
Hangleton commented on PR #13240:
URL: https://github.com/apache/kafka/pull/13240#issuecomment-1452495333
Thanks David for the review, have a few more tests to add but this should be
eligible to another pass.
--
This is an automated message from the Apache Git Service.
To respond to the
C0urante merged PR #13182:
URL: https://github.com/apache/kafka/pull/13182
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-14533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695888#comment-17695888
]
Guozhang Wang commented on KAFKA-14533:
---
After some investigation I found the following:
1. In
guozhangwang commented on code in PR #13318:
URL: https://github.com/apache/kafka/pull/13318#discussion_r1123632054
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java:
##
@@ -143,6 +145,33 @@ public static KafkaFuture> fetchEndOf
dajac opened a new pull request, #13329:
URL: https://github.com/apache/kafka/pull/13329
This patch adds ConsumerGroupHeartbeat to the GroupCoordinator interface and
implements the API in KafkaApis.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
dajac merged PR #13322:
URL: https://github.com/apache/kafka/pull/13322
--
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:
junrao commented on code in PR #13304:
URL: https://github.com/apache/kafka/pull/13304#discussion_r1123584048
##
storage/src/main/java/org/apache/kafka/storage/internals/log/FetchDataInfo.java:
##
@@ -44,6 +45,28 @@ public FetchDataInfo(LogOffsetMetadata fetchOffsetMetadata,
[
https://issues.apache.org/jira/browse/KAFKA-14773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695862#comment-17695862
]
Chris Egerton edited comment on KAFKA-14773 at 3/2/23 6:49 PM:
---
The
[
https://issues.apache.org/jira/browse/KAFKA-14773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695862#comment-17695862
]
Chris Egerton commented on KAFKA-14773:
---
The shell script encompasses the entire lifetime of MM2;
C0urante commented on code in PR #13284:
URL: https://github.com/apache/kafka/pull/13284#discussion_r1123546376
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java:
##
@@ -322,6 +324,29 @@ public void run() {
}
}
+/**
+ *
guozhangwang commented on code in PR #13301:
URL: https://github.com/apache/kafka/pull/13301#discussion_r1123543033
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchManagerMetrics.java:
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache Software
dajac commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123529173
##
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java:
##
@@ -118,11 +123,78 @@ public AddPartitionsToTxnRequestData data() {
dajac commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123527995
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1328,7 +1328,7 @@ Priority priority() {
@Override
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123526676
##
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java:
##
@@ -118,11 +123,78 @@ public AddPartitionsToTxnRequestData data() {
[
https://issues.apache.org/jira/browse/KAFKA-14746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695852#comment-17695852
]
Mickael Maison commented on KAFKA-14746:
https://issues.apache.org/jira/browse/KAFKA-14732
dajac commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123517021
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1303,11 +1305,13 @@ public void
C0urante commented on PR #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-1452296446
@urbandan I've given the "tweak" fix (i.e., altering `ConnectSchema::equals`
to use interface methods and accept any `Schema` instance during equality
checking) a shot locally and,
dajac commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123514453
##
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java:
##
@@ -118,11 +123,78 @@ public AddPartitionsToTxnRequestData data() {
jolshan commented on code in PR #13322:
URL: https://github.com/apache/kafka/pull/13322#discussion_r1123513945
##
core/src/main/scala/kafka/server/KafkaConfig.scala:
##
@@ -1267,6 +1314,24 @@ object KafkaConfig {
.define(GroupInitialRebalanceDelayMsProp, INT,
[
https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695848#comment-17695848
]
Matthias J. Sax commented on KAFKA-14747:
-
You would create a branch from `trunk` – for more
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123508496
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1328,7 +1328,7 @@ Priority priority() {
@Override
[
https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695846#comment-17695846
]
Matthias J. Sax commented on KAFKA-9234:
[~rndgstn] did look into the PRs - maybe he knows best?
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123503881
##
clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java:
##
@@ -118,11 +123,78 @@ public AddPartitionsToTxnRequestData data() {
dajac commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1452269739
@CalvinConfluent Thanks for the explanation. I agree that we have two
options on the table: 1) pass the api version or even the header object; or 2)
rely on the default sentinel value to
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123501064
##
clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java:
##
@@ -1303,11 +1305,13 @@ public void
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1123499195
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -2384,68 +2385,116 @@ class KafkaApis(val requestChannel: RequestChannel,
if
CalvinConfluent commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1452256725
@dajac I think the major question is how can the KafkaRaftClient can
correctly consume the FetchRequest.
The current PR makes quite some efforts to get the FetchRequest
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1123476762
##
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java:
##
@@ -337,8 +362,27 @@ public AbstractResponse getErrorResponse(int
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1123475771
##
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java:
##
@@ -302,6 +315,18 @@ public String toString() {
}
}
+public
mimaison opened a new pull request, #13328:
URL: https://github.com/apache/kafka/pull/13328
…onfig
Otherwise calls to `checkpointsTopic()`, whcih happen relatively frequently,
keep creating new ReplicationPolicy instances.
### Committer Checklist (excluded from commit
satishd commented on PR #13275:
URL: https://github.com/apache/kafka/pull/13275#issuecomment-1452242033
Thanks @junrao for your review. Addressed your comments inline and/or
updated with the latest commit.
--
This is an automated message from the Apache Git Service.
To respond to the
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1123469847
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -936,13 +937,13 @@ private CompletableFuture
handleFetchRequest(
C0urante commented on code in PR #13185:
URL: https://github.com/apache/kafka/pull/13185#discussion_r1123470094
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -243,7 +248,11 @@ public synchronized void
C0urante commented on code in PR #13185:
URL: https://github.com/apache/kafka/pull/13185#discussion_r1123467255
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -243,7 +248,11 @@ public synchronized void
C0urante commented on code in PR #13185:
URL: https://github.com/apache/kafka/pull/13185#discussion_r1120754565
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -243,7 +248,11 @@ public synchronized void
[
https://issues.apache.org/jira/browse/KAFKA-14747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695817#comment-17695817
]
Koma Zhang commented on KAFKA-14747:
Thank u guys, so for me as the developer, which branch i can
chia7712 opened a new pull request, #13327:
URL: https://github.com/apache/kafka/pull/13327
send readers a reminder: the total number of network threads is `listeners *
num.network.threads`
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
satishd commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1123369985
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
satishd commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1123045997
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -0,0 +1,407 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
urbandan commented on PR #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-1452111290
@C0urante I'm also hesitant to change the API, but I think this part of the
API is broken. If we tweak ConnectSchema::equals to use the Schema interface
methods, then setting the
C0urante commented on code in PR #13185:
URL: https://github.com/apache/kafka/pull/13185#discussion_r1120754565
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -243,7 +248,11 @@ public synchronized void
[
https://issues.apache.org/jira/browse/KAFKA-12550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12550:
-
Assignee: (was: Sagar Rao)
> Introduce RESTORING state to the KafkaStreams FSM
>
[
https://issues.apache.org/jira/browse/KAFKA-13501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13501:
-
Assignee: (was: Sagar Rao)
> Avoid state restore via rebalance if standbys are enabled
>
[
https://issues.apache.org/jira/browse/KAFKA-13499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13499:
-
Assignee: (was: Sagar Rao)
> Avoid restoring outdated records
>
[
https://issues.apache.org/jira/browse/KAFKA-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-12957:
-
Assignee: (was: Sagar Rao)
> Refactor Streams Logical Plan Generation
>
[
https://issues.apache.org/jira/browse/KAFKA-13336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13336:
-
Assignee: (was: Sagar Rao)
> Migrate StreamsBuilder/Topology class to interfaces and move
[
https://issues.apache.org/jira/browse/KAFKA-13349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13349:
-
Assignee: (was: Sagar Rao)
> Allow Iterator.remove on KeyValueIterator
>
[
https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13555:
-
Assignee: (was: Sagar Rao)
> Consider number if input topic partitions for task assignment
C0urante commented on code in PR #13185:
URL: https://github.com/apache/kafka/pull/13185#discussion_r1123318824
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/IsolatedPlugin.java:
##
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14585:
-
Assignee: (was: Sagar Rao)
> Move StorageTool to tools
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14487:
-
Assignee: (was: Sagar Rao)
> Move LogManager to storage module
>
mimaison commented on code in PR #13215:
URL: https://github.com/apache/kafka/pull/13215#discussion_r1123250142
##
tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java:
##
@@ -0,0 +1,397 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
C0urante commented on code in PR #13182:
URL: https://github.com/apache/kafka/pull/13182#discussion_r1123292638
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java:
##
@@ -419,7 +423,14 @@ private Collection>
C0urante commented on code in PR #13182:
URL: https://github.com/apache/kafka/pull/13182#discussion_r1123292197
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java:
##
@@ -111,20 +115,62 @@ public enum TestPlugin {
/**
chia7712 opened a new pull request, #13326:
URL: https://github.com/apache/kafka/pull/13326
Users can alter broker configuration to remove specify listeners. However,
the removed listeners are NOT removed from `reconfigurables` list. It can
result in the idle processors if users increases
[
https://issues.apache.org/jira/browse/KAFKA-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-13702:
--
Fix Version/s: 3.3.3
> Connect RestClient overrides response status code on request failure
>
Chia-Ping Tsai created KAFKA-14774:
--
Summary: the removed listeners should not be reconfigurable
Key: KAFKA-14774
URL: https://issues.apache.org/jira/browse/KAFKA-14774
Project: Kafka
Issue
C0urante merged PR #13287:
URL: https://github.com/apache/kafka/pull/13287
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-14771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierangelo Di Pilato updated KAFKA-14771:
-
Fix Version/s: (was: 3.3)
> Include current thread ids in
[
https://issues.apache.org/jira/browse/KAFKA-14771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierangelo Di Pilato updated KAFKA-14771:
-
Fix Version/s: 3.3
> Include current thread ids in
[
https://issues.apache.org/jira/browse/KAFKA-14771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierangelo Di Pilato reassigned KAFKA-14771:
Assignee: Pierangelo Di Pilato
> Include current thread ids in
divijvaidya commented on code in PR #13285:
URL: https://github.com/apache/kafka/pull/13285#discussion_r1123127295
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -115,22 +115,15 @@ class SocketServer(val config: KafkaConfig,
private var stopped = false
dajac commented on code in PR #12813:
URL: https://github.com/apache/kafka/pull/12813#discussion_r1123117911
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -641,7 +643,7 @@ private void completeBatch(ProducerBatch batch,
chia7712 commented on code in PR #13285:
URL: https://github.com/apache/kafka/pull/13285#discussion_r1123116645
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -115,22 +115,23 @@ class SocketServer(val config: KafkaConfig,
private var stopped = false
//
dajac commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1123094538
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -936,13 +937,13 @@ private CompletableFuture
handleFetchRequest(
RaftRequest.Inbound
pierDipi commented on PR #13325:
URL: https://github.com/apache/kafka/pull/13325#issuecomment-1451869239
cc for review @hachikuji @showuon
--
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
chia7712 commented on code in PR #13285:
URL: https://github.com/apache/kafka/pull/13285#discussion_r1123098018
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -141,8 +142,8 @@ class SocketServer(val config: KafkaConfig,
}
newGauge("MemoryPoolAvailable", ()
1 - 100 of 120 matches
Mail list logo