highluck commented on pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#issuecomment-824559138
@guozhangwang
The code has been modified.
If the phrase is strange, please tell me Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the
guozhangwang commented on a change in pull request #9640:
URL: https://github.com/apache/kafka/pull/9640#discussion_r618085808
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -110,7 +110,10 @@ public void
kkonstantine merged pull request #10580:
URL: https://github.com/apache/kafka/pull/10580
--
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.
For queries about this service,
kkonstantine commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824542872
Failures were not relevant.
--
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
melan closed pull request #840:
URL: https://github.com/apache/kafka/pull/840
--
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.
For queries about this service, please
wenbingshen commented on pull request #10586:
URL: https://github.com/apache/kafka/pull/10586#issuecomment-824529067
Dear @chia7712 , I request apply this pr to the 2.8 branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
wenbingshen opened a new pull request #10586:
URL: https://github.com/apache/kafka/pull/10586
Link to [KAFKA-12702](https://issues.apache.org/jira/browse/KAFKA-12702) ,
[10575](https://github.com/apache/kafka/pull/10575)
### Committer Checklist (excluded from commit message)
- [
chia7712 opened a new pull request #10585:
URL: https://github.com/apache/kafka/pull/10585
The command used by our private CI is `./gradlew cleanTest xxx:test`. It
does not re-run test when we use `unitTest` and `integrationTest` to replace
`test`. The root cause is that we don't offer
chia7712 merged pull request #10574:
URL: https://github.com/apache/kafka/pull/10574
--
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.
For queries about this service,
wenbingshen commented on pull request #10575:
URL: https://github.com/apache/kafka/pull/10575#issuecomment-824508678
> @wenbingshen As `Utils.isBlank(ep.host)` does not exist in 2.8, could you
file another PR for 2.8 branch?
Of course, I will do it now, thank you for your guidance.
chia7712 commented on pull request #10575:
URL: https://github.com/apache/kafka/pull/10575#issuecomment-824507357
@wenbingshen As `Utils.isBlank(ep.host)` does not exist in 2.8, could you
file another PR for 2.8 branch?
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jibitesh Prasad closed KAFKA-12621.
---
> Kafka setup with Zookeeper- specifying an alternate znode creates the
> configuration at the
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jibitesh Prasad resolved KAFKA-12621.
-
Resolution: Fixed
Incorrect configuration on my part
> Kafka setup with Zookeeper-
[
https://issues.apache.org/jira/browse/KAFKA-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327073#comment-17327073
]
Jibitesh Prasad commented on KAFKA-12621:
-
Thanks! I completely missed that.
> Kafka setup with
chia7712 merged pull request #10575:
URL: https://github.com/apache/kafka/pull/10575
--
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.
For queries about this service,
[
https://issues.apache.org/jira/browse/KAFKA-12705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12705:
Component/s: unit tests
> Task idling is not sufficiently tested
>
jolshan edited a comment on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824501282
@dengziming. I just saw this, so I didn't realize you were working on this
too. I should have paid better attention. I opened
https://github.com/apache/kafka/pull/10584
jolshan commented on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824501282
@dengziming. I should have paid attention. I just saw this. I opened
https://github.com/apache/kafka/pull/10584
--
This is an automated message from the Apache Git Service.
jolshan opened a new pull request #10584:
URL: https://github.com/apache/kafka/pull/10584
We prevent handling MetadataRequests where the topic name is null (to
prevent NPE) as well as prevent requests that set topic IDs since this
functionality has not yet been implemented. When we do
mjsax merged pull request #10565:
URL: https://github.com/apache/kafka/pull/10565
--
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.
For queries about this service, please
jolshan commented on pull request #10583:
URL: https://github.com/apache/kafka/pull/10583#issuecomment-824496045
Closed, will retarget 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
jolshan closed pull request #10583:
URL: https://github.com/apache/kafka/pull/10583
--
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.
For queries about this service,
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618025026
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +908,32 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618021571
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +907,33 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on a change in pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#discussion_r618021571
##
File path: core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala
##
@@ -905,19 +907,33 @@ class GroupCoordinator(val brokerId: Int,
*
hachikuji commented on pull request #10483:
URL: https://github.com/apache/kafka/pull/10483#issuecomment-824473278
@chia7712 Thanks for the comments. I finally had a chance to address them.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
hachikuji commented on a change in pull request #10483:
URL: https://github.com/apache/kafka/pull/10483#discussion_r618008786
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/TransactionState.java
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software
jolshan opened a new pull request #10583:
URL: https://github.com/apache/kafka/pull/10583
This is the change for 2.8 that should be used in 2.8.1. We prevent handling
MetadataRequests where the topic name is null (to prevent NPE) as well as
prevent requests that set topic IDs since this
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326652#comment-17326652
]
Justine Olshan edited comment on KAFKA-12701 at 4/22/21, 12:09 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326909#comment-17326909
]
Justine Olshan edited comment on KAFKA-12701 at 4/22/21, 12:09 AM:
---
ableegoldman commented on a change in pull request #10542:
URL: https://github.com/apache/kafka/pull/10542#discussion_r617962722
##
File path:
streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java
##
@@ -177,9 +177,8 @@ public static
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327015#comment-17327015
]
Jason Gustafson commented on KAFKA-9772:
My mistake. This case is a little different than I
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327007#comment-17327007
]
A. Sophie Blee-Goldman commented on KAFKA-12699:
Marking it down for 3.0 so we don't
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12699:
---
Fix Version/s: 3.0.0
> Streams no longer overrides the java default
[
https://issues.apache.org/jira/browse/KAFKA-12699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17327006#comment-17327006
]
A. Sophie Blee-Goldman commented on KAFKA-12699:
> we should have the exception raised
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson reassigned KAFKA-9772:
--
Assignee: Jason Gustafson
> Transactional offset commit fails with
[
https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326994#comment-17326994
]
Jason Gustafson commented on KAFKA-9772:
I noticed this recently in our logs. I believe the error
A. Sophie Blee-Goldman created KAFKA-12706:
--
Summary: Consider adding reason and source of error in
APPLICATION_SHUTDOWN
Key: KAFKA-12706
URL: https://issues.apache.org/jira/browse/KAFKA-12706
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617936154
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617936154
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617935620
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
Walker Carlson created KAFKA-12705:
--
Summary: Task idling is not sufficiently tested
Key: KAFKA-12705
URL: https://issues.apache.org/jira/browse/KAFKA-12705
Project: Kafka
Issue Type:
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617904827
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/AbstractApiMessageAndVersionSerde.java
##
@@ -0,0
junrao commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617858509
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -172,47 +174,54 @@ String diff(PartitionControlInfo
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326909#comment-17326909
]
Justine Olshan commented on KAFKA-12701:
[~dengziming] I can work on the 2.8 version where we
wcarlson5 commented on a change in pull request #10565:
URL: https://github.com/apache/kafka/pull/10565#discussion_r617857575
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -667,8 +668,15 @@ public boolean
ableegoldman closed pull request #10581:
URL: https://github.com/apache/kafka/pull/10581
--
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.
For queries about this service,
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617845243
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617844560
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-824325232
> All of them already had the checks.
Sweet. I did not double check the code before.
Seems, `put(final Windowed sessionKey,...)` and `remove(final Windowed
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617842172
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617839610
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
mjsax commented on a change in pull request #10573:
URL: https://github.com/apache/kafka/pull/10573#discussion_r617826977
##
File path:
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
##
@@ -642,9 +647,13 @@ public void beginTransaction() throws
ableegoldman commented on pull request #10582:
URL: https://github.com/apache/kafka/pull/10582#issuecomment-824320067
Cherrypicked back to 2.8 and 2.7
--
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
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617836508
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
ableegoldman commented on a change in pull request #10581:
URL: https://github.com/apache/kafka/pull/10581#discussion_r617836508
##
File path: gradle/dependencies.gradle
##
@@ -166,6 +166,7 @@ libs += [
kafkaStreams_23: "org.apache.kafka:kafka-streams:$versions.kafka_23",
[
https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326876#comment-17326876
]
Kirill Rodionov edited comment on KAFKA-5761 at 4/21/21, 7:54 PM:
--
If
[
https://issues.apache.org/jira/browse/KAFKA-5761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326876#comment-17326876
]
Kirill Rodionov commented on KAFKA-5761:
If we're talking pooled/reused buffers (like Netty's
ableegoldman merged pull request #10582:
URL: https://github.com/apache/kafka/pull/10582
--
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.
For queries about this service,
ableegoldman opened a new pull request #10582:
URL: https://github.com/apache/kafka/pull/10582
--
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.
For queries about this
ableegoldman opened a new pull request #10581:
URL: https://github.com/apache/kafka/pull/10581
Seems this was missed to add during the original 2.6.0 release
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
kpatelatwork commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824306271
done
--
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.
[
https://issues.apache.org/jira/browse/KAFKA-10493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326860#comment-17326860
]
Matthias J. Sax commented on KAFKA-10493:
-
Thinking about this ticket once more, I actually have
C0urante commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824300835
Sure, I mean this:
```java
private ConcurrentMap tempConnectors = new
ConcurrentHashMap<>();
```
--
This is an automated message from the Apache Git Service.
To
kpatelatwork commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824299926
> We may want to upgrade `tempConnectors` from a regular `Map` to a
`ConcurrentMap` as well, LGTM otherwise though.
it's already a ConcurrentHashMap :).
`
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326845#comment-17326845
]
Matthias J. Sax commented on KAFKA-12696:
-
{quote}Ok. Just to confirm, the confluence where KIPs
C0urante edited a comment on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something
C0urante edited a comment on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something
C0urante commented on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824292010
Hmm... I'm wondering if this might break existing setups. Since the
`SchemaBuilder` class does implement the `Schema` interface, it's currently
possible to do something like
ableegoldman commented on a change in pull request #10565:
URL: https://github.com/apache/kafka/pull/10565#discussion_r617805969
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -667,8 +668,15 @@ public boolean
Naros commented on pull request #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-824277958
@C0urante @rhauch , could either of you review this to see if its acceptable?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman merged pull request #10570:
URL: https://github.com/apache/kafka/pull/10570
--
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.
For queries about this service,
cmccabe commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617785244
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1119,6 +1053,62 @@ void
junrao commented on a change in pull request #10564:
URL: https://github.com/apache/kafka/pull/10564#discussion_r617773890
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -321,22 +339,17 @@ public void
C0urante commented on pull request #10580:
URL: https://github.com/apache/kafka/pull/10580#issuecomment-824267968
We may want to upgrade `tempConnectors` from a regular `Map` to a
`ConcurrentMap` as well, LGTM otherwise though.
--
This is an automated message from the Apache Git
kpatelatwork opened a new pull request #10580:
URL: https://github.com/apache/kafka/pull/10580
*Concurrent requests to validate endpoint for the same connector type calls
AbstractHerder::getConnector to get the cached connector instances and if the
connector hasn't been cached yet then
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617765100
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java
##
@@ -0,0
junrao commented on pull request #10576:
URL: https://github.com/apache/kafka/pull/10576#issuecomment-824228739
@dengziming : We probably can't remove a field from an existing protocol
without changing the version. Otherwise, the client will be confused on the
exact protocol for a
[
https://issues.apache.org/jira/browse/KAFKA-9560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-9560:
-
Description:
Requests to the {{PUT /connector-plugins/\{connectorType}/config/validate}}
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-12704:
--
Description:
As discovered in KAFKA-9560, concurrent requests to the {{PUT
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel updated KAFKA-12704:
--
Description:
Concurrent requests to the {{PUT
[
https://issues.apache.org/jira/browse/KAFKA-12704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kalpesh Patel reassigned KAFKA-12704:
-
Assignee: Kalpesh Patel
> Concurrent calls to AbstractHerder::getConnector can
Kalpesh Patel created KAFKA-12704:
-
Summary: Concurrent calls to AbstractHerder::getConnector can
potentially create two connector instances
Key: KAFKA-12704
URL: https://issues.apache.org/jira/browse/KAFKA-12704
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326652#comment-17326652
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:58 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326628#comment-17326628
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:49 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326628#comment-17326628
]
Justine Olshan edited comment on KAFKA-12701 at 4/21/21, 3:49 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326652#comment-17326652
]
Justine Olshan commented on KAFKA-12701:
[~dengziming] Just to clarify, we did not yet implement
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326641#comment-17326641
]
Ismael Juma commented on KAFKA-12696:
-
The "avoid getters and setters" note applies to both Java and
[
https://issues.apache.org/jira/browse/KAFKA-12696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326635#comment-17326635
]
Mikhail Panchenko commented on KAFKA-12696:
---
Ok. Just to confirm, the confluence where KIPs
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326633#comment-17326633
]
Ismael Juma commented on KAFKA-12701:
-
I suggest fixing it in 3.0.0 and 2.8.1.
> NPE in
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617482721
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java
##
@@ -0,0
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r617482721
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataContextSerdes.java
##
@@ -0,0
[
https://issues.apache.org/jira/browse/KAFKA-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326628#comment-17326628
]
Justine Olshan commented on KAFKA-12701:
Thanks [~twmb] and [~dengziming] for taking a look at
kpatelatwork commented on pull request #10530:
URL: https://github.com/apache/kafka/pull/10530#issuecomment-824141840
@tombentley I took another shot of implementing the PR using the above
suggestions.
Could you please check if it still needs improvement?
I didn't do
Nathan22177 commented on pull request #10548:
URL: https://github.com/apache/kafka/pull/10548#issuecomment-824141690
@mjsax
> MeteredSessionStore:
>
> * put() (should verify `sessionKey != null` and `sessionKey.key() != null`)
> * remove()
> * fetchSession()
> * fetch(K)
[
https://issues.apache.org/jira/browse/KAFKA-10800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326611#comment-17326611
]
Haoran Xuan commented on KAFKA-10800:
-
Hi, [~jagsancio], I just started working on this task, and
[
https://issues.apache.org/jira/browse/KAFKA-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326600#comment-17326600
]
Wenbing Shen commented on KAFKA-10773:
--
Similar to KAFKA-12680. In fact, this is a bug of wsl. The
[
https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen resolved KAFKA-12680.
--
Resolution: Not A Problem
> Failed to restart the broker in kraft mode
>
[
https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenbing Shen reopened KAFKA-12680:
--
> Failed to restart the broker in kraft mode
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17326589#comment-17326589
]
Wenbing Shen commented on KAFKA-12680:
--
Hi [~ijuma] Sorry, this problem is caused by me. In fact,
1 - 100 of 141 matches
Mail list logo
