chia7712 commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-730231950
(I'm still reading this story so pardon me for asking stupid question.)
If using timestamp=0 can bring correct offset, why not following that way to
handle ```ListOffsetReq
[
https://issues.apache.org/jira/browse/KAFKA-10656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235305#comment-17235305
]
Tom Bentley commented on KAFKA-10656:
-
[~cmccabe] I opened a PR for this, please cou
dajac commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r526710893
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -122,6 +123,14 @@ public void writeVarlong(long i) {
Byt
dajac commented on a change in pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#discussion_r526718951
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
##
@@ -659,6 +655,12 @@ else if (error == Errors.CLUSTER_AUTHORIZ
dajac commented on pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#issuecomment-730250619
I have triggered another run of the CI. I will merge it afterwards.
This is an automated message from the Apache Git
dajac commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526729269
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1324,7 +1404,60 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics:
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235343#comment-17235343
]
Tim Fox commented on KAFKA-10114:
-
> We are still seeing this issue with version 2.6.0.
dajac commented on pull request #9547:
URL: https://github.com/apache/kafka/pull/9547#issuecomment-730285178
Failed test seems unrelated to this PR. Merging to trunk.
This is an automated message from the Apache Git Service.
dajac merged pull request #9547:
URL: https://github.com/apache/kafka/pull/9547
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
[
https://issues.apache.org/jira/browse/KAFKA-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-9630.
Fix Version/s: 2.8.0
Resolution: Fixed
> Replace OffsetsForLeaderEpoch request/response with
dajac commented on pull request #9601:
URL: https://github.com/apache/kafka/pull/9601#issuecomment-730287841
@gardnervickers https://github.com/apache/kafka/pull/9401 and
https://github.com/apache/kafka/pull/9547 have been merged. You can bring them
back in this PR if you like.
-
dajac commented on pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#issuecomment-730292123
@anatasiavela Both PRs have been merged so we can proceed with this one.
There is something that we must consider that I was not aware of:
https://github.com/apache/kafka/blob
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235343#comment-17235343
]
Tim Fox edited comment on KAFKA-10114 at 11/19/20, 11:09 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235343#comment-17235343
]
Tim Fox edited comment on KAFKA-10114 at 11/19/20, 11:14 AM:
-
bristy opened a new pull request #9621:
URL: https://github.com/apache/kafka/pull/9621
*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.*
FileChannel.close() does n
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235343#comment-17235343
]
Tim Fox edited comment on KAFKA-10114 at 11/19/20, 11:53 AM:
-
dengziming opened a new pull request #9622:
URL: https://github.com/apache/kafka/pull/9622
*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.*
1. Bump the versio
dengziming commented on pull request #9622:
URL: https://github.com/apache/kafka/pull/9622#issuecomment-730332596
@rajinisivaram @jolshan Hi, PTAL.
This is an automated message from the Apache Git Service.
To respond to the m
tombentley opened a new pull request #9623:
URL: https://github.com/apache/kafka/pull/9623
Add delegation.token.secret.key broker config and deprecate
delegation.token.master.key as described in
[KIP-681](https://cwiki.apache.org/confluence/display/KAFKA/KIP-681%3A+Rename+master+key+in+del
tombentley commented on pull request #9623:
URL: https://github.com/apache/kafka/pull/9623#issuecomment-730336828
@omkreddy, @mimaison please could one of you review?
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235343#comment-17235343
]
Tim Fox edited comment on KAFKA-10114 at 11/19/20, 1:17 PM:
ijuma commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r526911200
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1333,7 +1343,17 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
mumrah commented on pull request #9598:
URL: https://github.com/apache/kafka/pull/9598#issuecomment-730402458
@quanuw there are some statements that expect `joinStart` to be a timestamp
in order to calculate durations. When it's zero, those durations become huge
which leads to subsequent c
mumrah merged pull request #9598:
URL: https://github.com/apache/kafka/pull/9598
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
[
https://issues.apache.org/jira/browse/KAFKA-9892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235516#comment-17235516
]
Brajesh Kumar commented on KAFKA-9892:
---
[~ijuma]Can you please help me with build
cadonna commented on a change in pull request #9614:
URL: https://github.com/apache/kafka/pull/9614#discussion_r526880412
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1070,7 +1070,9 @@ private Thread shutdownHelper(final boolean error) {
mimaison merged pull request #9545:
URL: https://github.com/apache/kafka/pull/9545
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 t
dajac commented on pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#issuecomment-730447091
Builds are green. Merging to trunk.
This is an automated message from the Apache Git Service.
To respond to the mess
ryannedolan commented on pull request #9545:
URL: https://github.com/apache/kafka/pull/9545#issuecomment-730448017
Sorry, late to the convo, but lgtm, thanks!
This is an automated message from the Apache Git Service.
To respo
mimaison merged pull request #9623:
URL: https://github.com/apache/kafka/pull/9623
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 t
[
https://issues.apache.org/jira/browse/KAFKA-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10692.
Fix Version/s: 2.8.0
Resolution: Fixed
> Rename broker master key config for KIP 68
dajac merged pull request #9386:
URL: https://github.com/apache/kafka/pull/9386
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
[
https://issues.apache.org/jira/browse/KAFKA-10024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10024.
-
Fix Version/s: 2.8.0
Resolution: Fixed
> Add dynamic configuration and enforce quota for
Benedikt Linse created KAFKA-10746:
--
Summary: Consumer poll timeout Expiration should be logged as
WARNING not INFO.
Key: KAFKA-10746
URL: https://issues.apache.org/jira/browse/KAFKA-10746
Project:
David Mao created KAFKA-10747:
-
Summary: Implement ClientQuota APIs for altering and describing IP
entity quotas
Key: KAFKA-10747
URL: https://issues.apache.org/jira/browse/KAFKA-10747
Project: Kafka
David Mao created KAFKA-10748:
-
Summary: Add IP connection rate throttling metric
Key: KAFKA-10748
URL: https://issues.apache.org/jira/browse/KAFKA-10748
Project: Kafka
Issue Type: Improvement
dajac commented on pull request #7498:
URL: https://github.com/apache/kafka/pull/7498#issuecomment-730458347
Failed tests are not related. Merging to trunk.
* Build / JDK 11 /
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
*
[
https://issues.apache.org/jira/browse/KAFKA-10746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benedikt Linse updated KAFKA-10746:
---
Description:
When a consumer does not poll regularly, and the `max.poll.interval.ms`
thresh
dajac merged pull request #7498:
URL: https://github.com/apache/kafka/pull/7498
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
[
https://issues.apache.org/jira/browse/KAFKA-9023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-9023.
Fix Version/s: 2.8.0
Resolution: Fixed
> Producer NETWORK_EXCEPTION response should log more
mimaison commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-730467364
> If we have to control the complexity, I would prefer to drop
testWithBrokerRestart and keep MirrorConnectorsIntegrationSSLTest, as it makes
sense to run simple validation in SS
[
https://issues.apache.org/jira/browse/KAFKA-10747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-10747:
--
Component/s: core
config
> Implement ClientQuota APIs for altering and describing IP
[
https://issues.apache.org/jira/browse/KAFKA-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-10748:
--
Component/s: network
core
> Add IP connection rate throttling metric
> --
David Mao created KAFKA-10749:
-
Summary: Add throttling of IPs by connection rate
Key: KAFKA-10749
URL: https://issues.apache.org/jira/browse/KAFKA-10749
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-10747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-10747:
--
Parent: KAFKA-10749
Issue Type: Sub-task (was: Improvement)
> Implement ClientQuota APIs for
[
https://issues.apache.org/jira/browse/KAFKA-10748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-10748:
--
Parent: KAFKA-10749
Issue Type: Sub-task (was: Improvement)
> Add IP connection rate throttli
[
https://issues.apache.org/jira/browse/KAFKA-10024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Mao updated KAFKA-10024:
--
Parent: KAFKA-10749
Issue Type: Sub-task (was: Improvement)
> Add dynamic configuration and e
mimaison commented on a change in pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#discussion_r527005533
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationSSLTest.java
##
@@ -0,0 +1,98 @@
+/*
+ *
tombentley commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730476432
@abbccdda I think we're just waiting for your review here. Thanks.
This is an automated message from the Apache
chia7712 commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730478145
@tombentley Could you trigger QA again?
This is an automated message from the Apache Git Service.
To respond to
tombentley commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730479015
@chia7712 I thought only committers can do that.
This is an automated message from the Apache Git Service.
To r
chia7712 commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730480556
IIRC, the retest command does not work currently. Could you rebase code to
trigger QA?
This is an automated mess
jolshan commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r527020272
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1749,6 +1752,9 @@ class Log(@volatile private var _dir: File,
checkIfMemoryMappedBuf
jolshan commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-730487839
@chia7712 The code path you linked is the code path beginningOffsets uses.
Are you suggesting removing `ListOffsetRequest.EARLIEST_TIMESTAMP` and
replacing it with 0?
--
chia7712 commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-730491021
> Are you suggesting removing ListOffsetRequest.EARLIEST_TIMESTAMP and
replacing it with 0?
yep, it seems like a simple solution without much changes. However, I have
not
wcarlson5 commented on pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#issuecomment-730500854
@cadonna @mjsax @vvcephei Part 3 of KIP-663 add threads is ready for review
This is an automated message from th
jolshan commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-730503145
@chia7712 I did think about this solution initially. I'm wondering if we do
want to update the segment offsets and logStartOffsets correctly though. If
that isn't as important the
[
https://issues.apache.org/jira/browse/KAFKA-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10549:
--
Assignee: Justine Olshan
> Add topic ID support to DeleteTopics,ListOffsets, OffsetFo
hachikuji commented on a change in pull request #9601:
URL: https://github.com/apache/kafka/pull/9601#discussion_r527045689
##
File path: core/src/main/scala/kafka/api/ApiVersion.scala
##
@@ -108,7 +108,9 @@ object ApiVersion {
// Bup Fetch protocol for Raft protocol (KIP-
abbccdda opened a new pull request #9624:
URL: https://github.com/apache/kafka/pull/9624
When leader append fails, we should trigger the resign process and do a
graceful shutdown afterwards.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementat
tombentley commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730508481
@chia7712 done
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10548:
--
Assignee: Justine Olshan
> Implement deletion logic for LeaderAndIsrRequests
> --
chia7712 commented on pull request #9433:
URL: https://github.com/apache/kafka/pull/9433#issuecomment-730516709
@tombentley thanks! I will merge this PR tomorrow if no objection :)
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-10580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10580:
--
Assignee: Justine Olshan
> Add topic ID support to Fetch request
> --
Ning Zhang created KAFKA-10750:
--
Summary: test failure scenarios of MirrorMaker 2
Key: KAFKA-10750
URL: https://issues.apache.org/jira/browse/KAFKA-10750
Project: Kafka
Issue Type: Improvement
hachikuji commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r527073144
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -122,6 +123,14 @@ public void writeVarlong(long i) {
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r527073514
##
File path: raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java
##
@@ -709,6 +709,9 @@ static void verifyLeaderChangeMessage(
hachikuji commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r527073144
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -122,6 +123,14 @@ public void writeVarlong(long i) {
mimaison commented on a change in pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#discussion_r527014720
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -0,0 +1,407 @@
+/*
+
cadonna commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527055689
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,11 +904,57 @@ private KafkaStreams(final InternalTopologyBuilder
hachikuji commented on a change in pull request #9617:
URL: https://github.com/apache/kafka/pull/9617#discussion_r527095050
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -974,21 +969,6 @@ private void handleInitiateApiVersionRequests(long
hachikuji commented on a change in pull request #9617:
URL: https://github.com/apache/kafka/pull/9617#discussion_r527095539
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/CorrelationIdMismatchException.java
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apac
junrao commented on a change in pull request #8826:
URL: https://github.com/apache/kafka/pull/8826#discussion_r527096607
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -366,8 +379,9 @@ public void testMetadataFetch() throws I
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527099742
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,11 +904,57 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527099779
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,11 +904,57 @@ private KafkaStreams(final InternalTopologyBuilder
hachikuji commented on a change in pull request #9617:
URL: https://github.com/apache/kafka/pull/9617#discussion_r527101086
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/CorrelationIdMismatchException.java
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apac
junrao commented on a change in pull request #9621:
URL: https://github.com/apache/kafka/pull/9621#discussion_r527105252
##
File path: core/src/main/scala/kafka/log/ProducerStateManager.scala
##
@@ -437,7 +437,7 @@ object ProducerStateManager {
val fileChannel = FileChan
lct45 commented on a change in pull request #9614:
URL: https://github.com/apache/kafka/pull/9614#discussion_r527117685
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -221,6 +221,9 @@ State setState(final State newState
junrao merged pull request #9596:
URL: https://github.com/apache/kafka/pull/9596
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
cadonna commented on a change in pull request #9614:
URL: https://github.com/apache/kafka/pull/9614#discussion_r527122772
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -221,6 +221,9 @@ State setState(final State newSta
[
https://issues.apache.org/jira/browse/KAFKA-10723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10723.
-
Fix Version/s: 2.8.0
Resolution: Fixed
merged to trunk
> LogManager leaks internal thread pool a
Lucas Wang created KAFKA-10751:
--
Summary: Generate log to help estimate messages lost during ULE
Key: KAFKA-10751
URL: https://issues.apache.org/jira/browse/KAFKA-10751
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235702#comment-17235702
]
Lucas Wang commented on KAFKA-10751:
PR submitted: https://github.com/apache/kafka/p
cadonna commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527145996
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -588,6 +592,29 @@ public void testCloseIsIdempotent() {
hachikuji merged pull request #9619:
URL: https://github.com/apache/kafka/pull/9619
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
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-8872:
-
Assignee: Justine Olshan
> Improvements to controller "deleting" state / topic Identifi
lmr3796 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r527192802
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1333,7 +1343,17 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
hachikuji merged pull request #9608:
URL: https://github.com/apache/kafka/pull/9608
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
[
https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235769#comment-17235769
]
Daniel Dube commented on KAFKA-9458:
Hi everyone. "Windows is not an officially suppo
[
https://issues.apache.org/jira/browse/KAFKA-9458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235769#comment-17235769
]
Daniel Dube edited comment on KAFKA-9458 at 11/19/20, 10:10 PM:
---
Hamza-Slama opened a new pull request #9625:
URL: https://github.com/apache/kafka/pull/9625
*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 testi
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527277135
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,11 +904,72 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r527277048
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,11 +904,72 @@ private KafkaStreams(final InternalTopologyBuilder
jolshan opened a new pull request #9626:
URL: https://github.com/apache/kafka/pull/9626
This change takes the topic IDs created in
https://github.com/apache/kafka/pull/9473 and propagates them to brokers using
LeaderAndIsr Request. It also removes the topic name from the LeaderAndIsr
Resp
[
https://issues.apache.org/jira/browse/KAFKA-10547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235796#comment-17235796
]
Justine Olshan commented on KAFKA-10547:
Hi [~dengziming] I'm sorry I didn't see
jolshan commented on pull request #9622:
URL: https://github.com/apache/kafka/pull/9622#issuecomment-730710397
Hi @dengziming! Thanks for the PR! I was hoping to add LeaderAndIsrRequests
before UpdateMetadata/Metadata, as ordered in the [JIRA
ticket.](https://issues.apache.org/jira/browse/
jolshan edited a comment on pull request #9622:
URL: https://github.com/apache/kafka/pull/9622#issuecomment-730710397
Hi @dengziming! Thanks for the PR! I was hoping to add LeaderAndIsrRequests
before UpdateMetadata/Metadata, following the ordering of the [JIRA
tickets.](https://issues.ap
jolshan edited a comment on pull request #9622:
URL: https://github.com/apache/kafka/pull/9622#issuecomment-730710397
Hi @dengziming! Thanks for the PR! I was hoping to add LeaderAndIsrRequests
before UpdateMetadata/Metadata, following the ordering of the [JIRA
tickets.](https://issues.ap
[
https://issues.apache.org/jira/browse/KAFKA-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NAYUSIK updated KAFKA-10745:
Issue Type: Bug (was: Improvement)
> Please let me know how I check the time which Source connector recei
[
https://issues.apache.org/jira/browse/KAFKA-10745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
NAYUSIK updated KAFKA-10745:
Issue Type: Improvement (was: Bug)
> Please let me know how I check the time which Source connector recei
1 - 100 of 153 matches
Mail list logo
