chia7712 commented on PR #16211:
URL: https://github.com/apache/kafka/pull/16211#issuecomment-2167362750
@showuon could you please fix the build error?
--
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 g
showuon commented on code in PR #16264:
URL: https://github.com/apache/kafka/pull/16264#discussion_r1639358954
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -556,10 +558,22 @@ public static Set
generateRandomTopicPartitions(int numTopic, in
* @retur
chia7712 commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1639296989
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1666,23 +1668,68 @@ private boolean initWithCommittedOffsetsIfNeed
showuon commented on code in PR #16264:
URL: https://github.com/apache/kafka/pull/16264#discussion_r1639351349
##
clients/src/test/java/org/apache/kafka/test/TestUtils.java:
##
@@ -556,10 +558,20 @@ public static Set
generateRandomTopicPartitions(int numTopic, in
* @retur
rodesai commented on code in PR #16337:
URL: https://github.com/apache/kafka/pull/16337#discussion_r1639348243
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -635,14 +634,10 @@ public void setStandbyUpdateListener(final
StandbyUpdateListener standbyL
showuon commented on PR #16319:
URL: https://github.com/apache/kafka/pull/16319#issuecomment-2167331023
Retriggering CI build:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-16319/6/
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
TaiJuWu commented on code in PR #15908:
URL: https://github.com/apache/kafka/pull/15908#discussion_r1639336398
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DescribeConsumerGroupTest.java:
##
@@ -16,834 +16,986 @@
*/
package org.apache.kafka.tools.consumer.grou
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
m1a2st commented on PR #16330:
URL: https://github.com/apache/kafka/pull/16330#issuecomment-2167253065
@chia7712, Thanks for your comment, PTAL
--
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
m1a2st commented on code in PR #16330:
URL: https://github.com/apache/kafka/pull/16330#discussion_r1639283310
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectIntegrationTestUtils.java:
##
@@ -16,28 +16,26 @@
*/
package org.apache.kafka.connect.int
chia7712 commented on code in PR #16317:
URL: https://github.com/apache/kafka/pull/16317#discussion_r1639281603
##
core/src/test/java/kafka/admin/ConfigCommandIntegrationTest.java:
##
@@ -515,14 +524,19 @@ private void deleteAndVerifyConfig(Admin client,
Optional brokerId, Set<
aliehsaeedii commented on code in PR #16332:
URL: https://github.com/apache/kafka/pull/16332#discussion_r1639280799
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -792,6 +792,9 @@ public void sendOffsetsToTransaction(Map offs
*
xiaoqingwanga commented on PR #16303:
URL: https://github.com/apache/kafka/pull/16303#issuecomment-2167234187
@gharris1727 Hey, I have made all the changes. Please feel free to review
the code again.
--
This is an automated message from the Apache Git Service.
To respond to the message, p
chia7712 commented on code in PR #16330:
URL: https://github.com/apache/kafka/pull/16330#discussion_r1639268606
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectIntegrationTestUtils.java:
##
@@ -16,28 +16,26 @@
*/
package org.apache.kafka.connect.i
chia7712 commented on code in PR #16328:
URL: https://github.com/apache/kafka/pull/16328#discussion_r1639258794
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/SharedTopicAdminTest.java:
##
@@ -46,14 +48,10 @@ public class SharedTopicAdminTest {
@Mock private
frankvicky commented on PR #16250:
URL: https://github.com/apache/kafka/pull/16250#issuecomment-2167221151
Hi @chia7712 , I have fixed the build error, PTAL
--
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
omkreddy merged PR #16274:
URL: https://github.com/apache/kafka/pull/16274
--
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
chia7712 merged PR #16254:
URL: https://github.com/apache/kafka/pull/16254
--
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
chia7712 commented on PR #16250:
URL: https://github.com/apache/kafka/pull/16250#issuecomment-2167204001
@frankvicky please fix the build error
--
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 PR #16297:
URL: https://github.com/apache/kafka/pull/16297#issuecomment-2167203133
@gongxuanzhang please fix the conflicts
--
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 th
chia7712 merged PR #16298:
URL: https://github.com/apache/kafka/pull/16298
--
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
kagarwal06 opened a new pull request, #16338:
URL: https://github.com/apache/kafka/pull/16338
*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 test
chia7712 commented on PR #16210:
URL: https://github.com/apache/kafka/pull/16210#issuecomment-2167190716
@dopuskh3 could you please fix the conflicts?
--
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
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
satishd commented on PR #16321:
URL: https://github.com/apache/kafka/pull/16321#issuecomment-2167183730
@jlprat This is a bug fix that addresses having a wrong metric in edge case
scenarios. It is good to have it merged in 3.8 too. Let me know if you are
fine with adding it as part of 3.8
philipnee commented on code in PR #16272:
URL: https://github.com/apache/kafka/pull/16272#discussion_r1639205859
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1512,7 +1513,9 @@ public void unsubscribe() {
}
satishd merged PR #16321:
URL: https://github.com/apache/kafka/pull/16321
--
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.
chia7712 commented on code in PR #16116:
URL: https://github.com/apache/kafka/pull/16116#discussion_r1639198546
##
transaction-coordinator/src/main/java/org/apache/kafka/coordinator/transaction/TransactionLogConfigs.java:
##
@@ -51,4 +60,16 @@ public final class TransactionLogCo
showuon commented on PR #16211:
URL: https://github.com/apache/kafka/pull/16211#issuecomment-2167155537
> @showuon can you update the description?
PR description updated. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on PR #15544:
URL: https://github.com/apache/kafka/pull/15544#issuecomment-2167147382
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 merge
showuon merged PR #16195:
URL: https://github.com/apache/kafka/pull/16195
--
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.
kamalcph commented on PR #16210:
URL: https://github.com/apache/kafka/pull/16210#issuecomment-2167137194
Test failures are unrelated. The failed test is an existing flaky one:
```
testCorrectnessForCacheAndIndexFilesWhenResizeCache() –
kafka.log.remote.RemoteIndexCacheTest
```
kamalcph commented on PR #16321:
URL: https://github.com/apache/kafka/pull/16321#issuecomment-2167136261
Test failures are unrelated.
--
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
chia7712 commented on PR #16116:
URL: https://github.com/apache/kafka/pull/16116#issuecomment-2167090246
wait a minute. it seems there are failed tests related to this PR
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-16116/19/tests
--
This is
mjsax commented on PR #15513:
URL: https://github.com/apache/kafka/pull/15513#issuecomment-2167050910
Thanks @gharris1727 -- 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
mjsax merged PR #15513:
URL: https://github.com/apache/kafka/pull/15513
--
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.or
chia7712 commented on code in PR #16323:
URL: https://github.com/apache/kafka/pull/16323#discussion_r1639102144
##
core/src/test/java/kafka/test/ClusterTestExtensionsTest.java:
##
@@ -232,4 +232,17 @@ public void
testNotSupportedNewGroupProtocols(ClusterInstance clusterInstance
chia7712 commented on code in PR #16324:
URL: https://github.com/apache/kafka/pull/16324#discussion_r1639091686
##
gradle/dependencies.gradle:
##
@@ -237,14 +237,14 @@ libs += [
pcollections: "org.pcollections:pcollections:$versions.pcollections",
opentelemetryProto:
"io.
mjsax commented on code in PR #16337:
URL: https://github.com/apache/kafka/pull/16337#discussion_r1639096220
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -635,14 +634,10 @@ public void setStandbyUpdateListener(final
StandbyUpdateListener standbyLis
lianetm commented on PR #16272:
URL: https://github.com/apache/kafka/pull/16272#issuecomment-2167024740
Build completed with 5 unrelates failures:
> Build / JDK 21 and Scala 2.13 / testFenceMultipleBrokers() –
org.apache.kafka.controller.QuorumControllerTest
> Build / JDK 21 and Sc
[
https://issues.apache.org/jira/browse/KAFKA-16879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16879.
Fix Version/s: 3.9.0
Resolution: Fixed
> SystemTime should use singleton mode
> ---
chia7712 merged PR #16266:
URL: https://github.com/apache/kafka/pull/16266
--
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
kirktrue commented on PR #16310:
URL: https://github.com/apache/kafka/pull/16310#issuecomment-2167013423
@jlprat—This Jira/PR is a blocker for the KIP-848 Java client work. It
sounds like we're really close to merging this within the next day or two.
Thanks!
--
This is an automated messa
xiaoqingwanga commented on code in PR #16303:
URL: https://github.com/apache/kafka/pull/16303#discussion_r1639075718
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java:
##
@@ -115,40 +118,54 @@ public ConsumerTask(RemotePartitionMetada
jolshan commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2166998275
Hey Omnia. Thanks for your work (and patience) so far. I will make another
deep pass tomorrow or early next week.
Things are looking good though.
--
This is an automated message fro
xiaoqingwanga commented on code in PR #16303:
URL: https://github.com/apache/kafka/pull/16303#discussion_r1639071233
##
storage/src/test/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTaskTest.java:
##
@@ -136,46 +128,46 @@ public void testUserTopicIdPartitionE
jolshan commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1639071024
##
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java:
##
@@ -34,10 +34,21 @@ public class ApiVersions {
private final Map nodeApiVersions = new
Ha
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1639052751
##
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java:
##
@@ -34,10 +34,21 @@ public class ApiVersions {
private final Map nodeApiVersions = new
Ha
chia7712 commented on PR #16116:
URL: https://github.com/apache/kafka/pull/16116#issuecomment-2166989084
> I think we can squeeze part of this vision in as it will reduce conflict
with this work going forward specially with the ongoing work for shared groups
and new coordinator which I want
[
https://issues.apache.org/jira/browse/KAFKA-16076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16076.
Fix Version/s: 3.9.0
Resolution: Fixed
> RestClient Interrupting the thread in case
chia7712 commented on PR #15110:
URL: https://github.com/apache/kafka/pull/15110#issuecomment-2166983767
this is fixed by #16282
--
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
chia7712 closed pull request #15110: KAFKA-16076: Interrupting the
currentThread fix
URL: https://github.com/apache/kafka/pull/15110
--
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 comm
chia7712 merged PR #16282:
URL: https://github.com/apache/kafka/pull/16282
--
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
chia7712 commented on PR #16282:
URL: https://github.com/apache/kafka/pull/16282#issuecomment-2166982488
all failed tests pass on my local. will merge it
--
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
OmniaGM commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2166980169
@dengziming I noticed that you had a look into this JIRA before and you
worked with Justine on the implementations of this KIP before. Would you be
able to provide some feedback on this P
[
https://issues.apache.org/jira/browse/KAFKA-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16954:
--
Component/s: clients
consumer
> Move consumer leave operations on close to background
OmniaGM commented on PR #15968:
URL: https://github.com/apache/kafka/pull/15968#issuecomment-2166973758
@chia7712 I noticed that you have reviewed parts of KIP-516 before, and I
was hoping you have some free time to review this one as well! Thanks in
advance
--
This is an automated mess
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1639052751
##
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java:
##
@@ -34,10 +34,21 @@ public class ApiVersions {
private final Map nodeApiVersions = new
Ha
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1639052751
##
clients/src/main/java/org/apache/kafka/clients/ApiVersions.java:
##
@@ -34,10 +34,21 @@ public class ApiVersions {
private final Map nodeApiVersions = new
Ha
OmniaGM closed pull request #16109: KAFKA-15853: Move ZKConfigs related static
method out of core and into ZKConfigs
URL: https://github.com/apache/kafka/pull/16109
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
OmniaGM commented on code in PR #15999:
URL: https://github.com/apache/kafka/pull/15999#discussion_r1639050807
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnectorTest.java:
##
@@ -50,6 +50,40 @@ public class MirrorCheckpointConnectorTest {
OmniaGM commented on code in PR #15999:
URL: https://github.com/apache/kafka/pull/15999#discussion_r1639046733
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceTaskTest.java:
##
@@ -437,6 +437,55 @@ public void testSendSyncEvent() {
verify(pro
kirktrue commented on PR #16241:
URL: https://github.com/apache/kafka/pull/16241#issuecomment-2166953380
Closing this PR as we have achieved consensus around the simpler solution in
#16310.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
kirktrue closed pull request #16241: KAFKA-16637: AsyncKafkaConsumer removes
offset fetch responses from cache too aggressively
URL: https://github.com/apache/kafka/pull/16241
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohan Desai reassigned KAFKA-16955:
---
Assignee: Rohan Desai
> ConcurrentModification exception thrown by KafkaStream threadState
rodesai opened a new pull request, #16337:
URL: https://github.com/apache/kafka/pull/16337
Each KafkaStreams instance maintains a map from threadId to state to use to
aggregate to a KafkaStreams app state. The map is updated on every state
change, and when a new thread is created. State cha
[
https://issues.apache.org/jira/browse/KAFKA-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohan Desai updated KAFKA-16955:
Affects Version/s: 3.7.0
> ConcurrentModification exception thrown by KafkaStream threadState acce
[
https://issues.apache.org/jira/browse/KAFKA-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohan Desai updated KAFKA-16955:
Component/s: streams
> ConcurrentModification exception thrown by KafkaStream threadState access
>
Rohan Desai created KAFKA-16955:
---
Summary: ConcurrentModification exception thrown by KafkaStream
threadState access
Key: KAFKA-16955
URL: https://issues.apache.org/jira/browse/KAFKA-16955
Project: Kafk
OmniaGM commented on code in PR #15999:
URL: https://github.com/apache/kafka/pull/15999#discussion_r1639020762
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java:
##
@@ -252,7 +252,13 @@ private static ConfigDef defineCheckpointConfig(Con
mjsax commented on PR #16316:
URL: https://github.com/apache/kafka/pull/16316#issuecomment-2166888575
Merged to `trunk` and cherry-picked to `3.8` and all the way back to `3.3`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1639005027
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -574,6 +581,148 @@ public void testPollLongThrowsException() {
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1639004424
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -574,6 +575,93 @@ public void testPollLongThrowsException() {
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1639004097
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -574,6 +575,93 @@ public void testPollLongThrowsException() {
mjsax merged PR #16316:
URL: https://github.com/apache/kafka/pull/16316
--
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.or
JimGalasyn commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1638978091
##
docs/ops.html:
##
@@ -3100,7 +3100,8 @@ Processor Node
Metrics
The following metrics are only available on certain types of nodes, i.e., the
process-* metrics
mjsax commented on PR #16313:
URL: https://github.com/apache/kafka/pull/16313#issuecomment-2166877068
Merged to `trunk` and cherry-picked to `3.8` and all the way back to `3.2`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
kirktrue commented on PR #16310:
URL: https://github.com/apache/kafka/pull/16310#issuecomment-2166875819
@AndrewJSchofield @cadonna @lianetm @philipnee: this PR is ready to be
re-reviewed. Thanks all for your input 😄
--
This is an automated message from the Apache Git Service.
To respond
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1638998663
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -574,6 +581,148 @@ public void testPollLongThrowsException() {
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1638996787
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1666,13 +1668,28 @@ private boolean initWithCommittedOffsetsIfNeed
JimGalasyn commented on code in PR #16336:
URL: https://github.com/apache/kafka/pull/16336#discussion_r1638992064
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,35 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
mjsax merged PR #16313:
URL: https://github.com/apache/kafka/pull/16313
--
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.or
JimGalasyn commented on code in PR #16336:
URL: https://github.com/apache/kafka/pull/16336#discussion_r1638991305
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,35 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
mjsax opened a new pull request, #16336:
URL: https://github.com/apache/kafka/pull/16336
(no comment)
--
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
kirktrue commented on code in PR #16310:
URL: https://github.com/apache/kafka/pull/16310#discussion_r1638982381
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -574,6 +581,148 @@ public void testPollLongThrowsException() {
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638981849
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638981412
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638981274
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638980584
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638980302
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638980033
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16313:
URL: https://github.com/apache/kafka/pull/16313#discussion_r1638979649
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,61 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1638978368
##
docs/streams/upgrade-guide.html:
##
@@ -303,6 +303,62 @@ Streams API
adds a new config default.client.supplier that allows to
use a custom KafkaClientSupp
JimGalasyn commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1638978091
##
docs/ops.html:
##
@@ -3100,7 +3100,8 @@ Processor Node
Metrics
The following metrics are only available on certain types of nodes, i.e., the
process-* metrics
JimGalasyn commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1638977635
##
docs/ops.html:
##
@@ -3100,7 +3100,8 @@ Processor Node
Metrics
The following metrics are only available on certain types of nodes, i.e., the
process-* metrics
JimGalasyn commented on code in PR #16316:
URL: https://github.com/apache/kafka/pull/16316#discussion_r1638977463
##
docs/ops.html:
##
@@ -3100,7 +3100,8 @@ Processor Node
Metrics
The following metrics are only available on certain types of nodes, i.e., the
process-* metrics
1 - 100 of 289 matches
Mail list logo
