chia7712 merged pull request #10400:
URL: https://github.com/apache/kafka/pull/10400
--
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, pleas
[
https://issues.apache.org/jira/browse/KAFKA-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322653#comment-17322653
]
Anchal Srivastava commented on KAFKA-10886:
---
[~wenbing.shen] Could you please
showuon opened a new pull request #10547:
URL: https://github.com/apache/kafka/pull/10547
The `MirrorConnectorsIntegrationTests` recently failed with
```
TimeoutException: The request timed out.
```
quite frequently. After investigation, the reason is the `createTopic` in
the s
chia7712 commented on a change in pull request #10498:
URL: https://github.com/apache/kafka/pull/10498#discussion_r614588327
##
File path: core/src/main/scala/kafka/tools/DumpLogSegments.scala
##
@@ -279,8 +279,10 @@ object DumpLogSegments {
if (batch.magic >=
chia7712 opened a new pull request #10546:
URL: https://github.com/apache/kafka/pull/10546
from https://github.com/apache/kafka/pull/10505#discussion_r614264455
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test cover
[
https://issues.apache.org/jira/browse/KAFKA-12676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-12676:
--
Description:
As discussed in KAFKA-12675, we think the general assignor algorithm might be
able to im
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322608#comment-17322608
]
Luke Chen commented on KAFKA-12675:
---
[~twmb], I see. I've created another ticket KAFKA
Luke Chen created KAFKA-12676:
-
Summary: Improve sticky general assignor underlying algorithm for
the imbalanced case
Key: KAFKA-12676
URL: https://issues.apache.org/jira/browse/KAFKA-12676
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322603#comment-17322603
]
Travis Bischel edited comment on KAFKA-12675 at 4/16/21, 4:25 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322603#comment-17322603
]
Travis Bischel edited comment on KAFKA-12675 at 4/16/21, 4:24 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322603#comment-17322603
]
Travis Bischel edited comment on KAFKA-12675 at 4/16/21, 4:10 AM:
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322603#comment-17322603
]
Travis Bischel commented on KAFKA-12675:
What I mean to say is that the logic po
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322599#comment-17322599
]
Luke Chen edited comment on KAFKA-12675 at 4/16/21, 3:59 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322599#comment-17322599
]
Luke Chen commented on KAFKA-12675:
---
[~twmb], thanks for suggestion. But in this ticke
ijuma commented on pull request #10545:
URL: https://github.com/apache/kafka/pull/10545#issuecomment-820886172
Merged to trunk and cherry-picked to 2.8.
--
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
ijuma merged pull request #10545:
URL: https://github.com/apache/kafka/pull/10545
--
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 c
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614538992
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
##
@@ -486,6 +486,327 @@ public void testJoin()
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614538557
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
##
@@ -486,6 +486,327 @@ public void testJoin()
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614538486
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
##
@@ -486,6 +486,327 @@ public void testJoin()
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614538200
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoinTest.java
##
@@ -486,6 +486,327 @@ public void testJoin()
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322593#comment-17322593
]
Travis Bischel commented on KAFKA-12675:
An option to evaluate is the algorithm
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614537097
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -93,23 +136,118 @@ public void process(final K
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614536735
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -211,6 +263,66 @@ private void assertUniqueStoreN
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614536011
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -118,20 +142,47 @@
final ProcessorGraphN
[
https://issues.apache.org/jira/browse/KAFKA-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-12675:
--
Description:
Currently, we have "general assignor" for non-equal subscription case and
"constrained a
Luke Chen created KAFKA-12675:
-
Summary: Improve sticky general assignor scalability and
performance
Key: KAFKA-12675
URL: https://issues.apache.org/jira/browse/KAFKA-12675
Project: Kafka
Issue
mjsax commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614534849
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -118,20 +142,47 @@
final ProcessorGraphN
Gwen Shapira created KAFKA-12674:
Summary: Client failover takes 2-4 seconds on clean broker shutdown
Key: KAFKA-12674
URL: https://issues.apache.org/jira/browse/KAFKA-12674
Project: Kafka
Is
junrao commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614448708
##
File path: storage/src/main/resources/message/RemotePartitionDeleteMetadata.json
##
@@ -0,0 +1,68 @@
+// Licensed to the Apache Software Foundation (ASF
[
https://issues.apache.org/jira/browse/KAFKA-12468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322537#comment-17322537
]
Jitesh Motwani edited comment on KAFKA-12468 at 4/15/21, 11:52 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-12468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322537#comment-17322537
]
Jitesh Motwani commented on KAFKA-12468:
[~askldjd]
what do you mean by run 10
guozhangwang commented on pull request #10294:
URL: https://github.com/apache/kafka/pull/10294#issuecomment-820756041
@jeqo could you rebase the PR while I review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
wcarlson5 commented on a change in pull request #10544:
URL: https://github.com/apache/kafka/pull/10544#discussion_r614398250
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -471,6 +472,10 @@ private void replaceStreamThread(final Throwable
wcarlson5 commented on a change in pull request #10544:
URL: https://github.com/apache/kafka/pull/10544#discussion_r614398250
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -471,6 +472,10 @@ private void replaceStreamThread(final Throwable
cmccabe commented on a change in pull request #10463:
URL: https://github.com/apache/kafka/pull/10463#discussion_r614404680
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -1119,6 +1148,113 @@ void validateManualPartitionAs
wcarlson5 commented on a change in pull request #10544:
URL: https://github.com/apache/kafka/pull/10544#discussion_r614398757
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1198,7 +1210,7 @@ int process(final int maxNum
bbejeck commented on pull request #10545:
URL: https://github.com/apache/kafka/pull/10545#issuecomment-820665466
@ijuma updated README
--
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 specifi
[
https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322417#comment-17322417
]
Guozhang Wang commented on KAFKA-12574:
---
Hi [~feyman] I'm aware of KAFKA-9689 as w
cmccabe commented on pull request #10505:
URL: https://github.com/apache/kafka/pull/10505#issuecomment-820659355
@chia7712: I re-ran the test failures locally and couldn't get them to occur.
The failures I saw were mostly streams tests... those have have been a bit
flaky lately... I
ijuma commented on pull request #10545:
URL: https://github.com/apache/kafka/pull/10545#issuecomment-820659248
Thanks for the PR. Don't you need to update the multi-node-quorum section?
https://github.com/apache/kafka/tree/trunk/raft#run-multi-node-quorum
--
This is an automated message
bbejeck opened a new pull request #10545:
URL: https://github.com/apache/kafka/pull/10545
Adding a property to the `raft/config/kraft.properties` for running the raft
test server in development.
For testing I ran `./bin/test-kraft-server-start.sh --config
config/kraft.properties` an
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614313362
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -93,23 +136,118 @@ public void process(final K
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614312924
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -211,6 +263,66 @@ private void assertUniqueStoreN
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614312224
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -211,6 +263,66 @@ private void assertUniqueStoreN
cmccabe merged pull request #10539:
URL: https://github.com/apache/kafka/pull/10539
--
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
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614304330
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -93,23 +136,118 @@ public void process(final K
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614303123
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -93,23 +136,118 @@ public void process(final K
[
https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-12672:
Description:
Running the {{test-kraft-server-start}} script in the {{raft}} module results
in thi
suhas created KAFKA-12673:
-
Summary: Kafka and zookeeper dependency
Key: KAFKA-12673
URL: https://issues.apache.org/jira/browse/KAFKA-12673
Project: Kafka
Issue Type: Task
Reporter: suhas
wcarlson5 commented on pull request #10544:
URL: https://github.com/apache/kafka/pull/10544#issuecomment-820620451
@ableegoldman This is what I think the error handling should look like. We
can try to categorize more but I think we should make this best effort and we
can add to it as we go
wcarlson5 opened a new pull request #10544:
URL: https://github.com/apache/kafka/pull/10544
changed the obvious ones to attribute to a named topology. This might be all
we need, we can always add more if they come up.
### Committer Checklist (excluded from commit message)
- [ ] Ve
[
https://issues.apache.org/jira/browse/KAFKA-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Travis Bischel updated KAFKA-12671:
---
Description:
If there is pathological processing of incoming produce requests and EndTxn
re
cmccabe merged pull request #10505:
URL: https://github.com/apache/kafka/pull/10505
--
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
wcarlson5 commented on pull request #10543:
URL: https://github.com/apache/kafka/pull/10543#issuecomment-820610403
@ableegoldman I tagged all the cases of StreamsExceptions that I think can
be attributed to a Sub topology. I may have missed some and some might not be
attributable. Also the
wcarlson5 opened a new pull request #10543:
URL: https://github.com/apache/kafka/pull/10543
change each StreamsException so that it has the sub topology name in it
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test co
chia7712 commented on a change in pull request #10505:
URL: https://github.com/apache/kafka/pull/10505#discussion_r614266078
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -242,87 +253,99 @@ class ControllerApis(val requestChannel: RequestChannel,
cmccabe commented on a change in pull request #10505:
URL: https://github.com/apache/kafka/pull/10505#discussion_r614264455
##
File path: core/src/main/scala/kafka/server/ControllerApis.scala
##
@@ -242,87 +253,99 @@ class ControllerApis(val requestChannel: RequestChannel,
[
https://issues.apache.org/jira/browse/KAFKA-12672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-12672:
Description:
Running the {{test-kraft-server-start}} script in the {{raft}} module results
in thi
Iskuskov commented on pull request #9541:
URL: https://github.com/apache/kafka/pull/9541#issuecomment-820596386
@chia7712, @ijuma, could you take a look at this please?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Bill Bejeck created KAFKA-12672:
---
Summary: Running test-kraft-server-start results in error
Key: KAFKA-12672
URL: https://issues.apache.org/jira/browse/KAFKA-12672
Project: Kafka
Issue Type: Bu
cmccabe merged pull request #10538:
URL: https://github.com/apache/kafka/pull/10538
--
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
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614230413
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java
##
@@ -105,6 +105,11 @@ public void remo
mumrah commented on a change in pull request #10505:
URL: https://github.com/apache/kafka/pull/10505#discussion_r614218074
##
File path: core/src/test/java/kafka/test/MockController.java
##
@@ -197,15 +209,73 @@ private MockController(Collection
initialTopics) {
@Overri
JoelWee commented on pull request #8923:
URL: https://github.com/apache/kafka/pull/8923#issuecomment-820560188
Thanks @ableegoldman and @wcarlson5! Will try to get this done over the next
week or so and ping you when ready :)
--
This is an automated message from the Apache Git Service.
C0urante commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614208924
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java
##
@@ -662,20 +666,94 @@ public void testSendReco
C0urante commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614208181
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java
##
@@ -120,6 +120,13 @@ public synchronized boolea
C0urante commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614207888
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java
##
@@ -105,6 +105,11 @@ public void remove(C
[
https://issues.apache.org/jira/browse/KAFKA-12574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322296#comment-17322296
]
Haoran Xuan commented on KAFKA-12574:
-
Hi, previously I was working on KAFKA-9689, i
wcarlson5 commented on a change in pull request #8923:
URL: https://github.com/apache/kafka/pull/8923#discussion_r614166802
##
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##
@@ -248,7 +257,7 @@ private void parseArguments(final String[] args) {
wcarlson5 commented on a change in pull request #8923:
URL: https://github.com/apache/kafka/pull/8923#discussion_r614166802
##
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##
@@ -248,7 +257,7 @@ private void parseArguments(final String[] args) {
kpatelatwork edited a comment on pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#issuecomment-820517908
@C0urante overall looks good and very good job on the tests but as I am new
to the code, I tried my best to review but I recommend getting a LGTM from one
more revi
[
https://issues.apache.org/jira/browse/KAFKA-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Travis Bischel updated KAFKA-12671:
---
Description:
If there is pathological processing of incoming produce requests and EndTxn
re
kpatelatwork commented on pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#issuecomment-820517908
@C0urante overall looks good but as I am new to the code, I tried my best
to review but I recommend getting a LGTM from one more reviewer also who knows
this code better t
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614162085
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java
##
@@ -662,20 +666,94 @@ public void testSend
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614161831
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java
##
@@ -662,20 +666,94 @@ public void testSend
vamossagar12 opened a new pull request #10542:
URL: https://github.com/apache/kafka/pull/10542
This PR aims to streamline the configurations for WindowedDeserialisers. It
deprecates default.windowed.key.serde.inner and
default.windowed.value.serde.inner configs in StreamConfig and adds
wi
dajac merged pull request #10540:
URL: https://github.com/apache/kafka/pull/10540
--
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 c
dajac commented on pull request #10540:
URL: https://github.com/apache/kafka/pull/10540#issuecomment-820497042
Test failures are not related. Merging 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 a
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614129645
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java
##
@@ -120,6 +120,13 @@ public synchronized bo
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614129645
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java
##
@@ -120,6 +120,13 @@ public synchronized bo
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614129645
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/OffsetStorageWriter.java
##
@@ -120,6 +120,13 @@ public synchronized bo
kpatelatwork commented on a change in pull request #10528:
URL: https://github.com/apache/kafka/pull/10528#discussion_r614126665
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceTaskOffsetCommitter.java
##
@@ -105,6 +105,11 @@ public void remo
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614114447
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java
##
@@ -60,20 +82,41 @@
}
private class K
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614105673
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -118,20 +142,47 @@
final ProcessorGraphN
spena commented on a change in pull request #10462:
URL: https://github.com/apache/kafka/pull/10462#discussion_r614098535
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImplJoin.java
##
@@ -118,20 +142,47 @@
final ProcessorGraphN
satishd commented on pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#issuecomment-820438379
@junrao This PR is rebased with the latest trunk and it is ready for review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
satishd commented on pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#issuecomment-820437818
Thanks @kowshik for the review. Addressed them with the latest
[5250b79](https://github.com/apache/kafka/pull/10271/commits/5250b79cef6d21c73d2b2a12ef7cd95a00e9f034).
--
This
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614083593
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serde/RemoteLogMetadataContextSerde.java
##
@@ -0,0 +1,115 @@
+/*
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614071198
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serde/RemoteLogSegmentMetadataSerde.java
##
@@ -0,0 +1,87 @@
+/*
ijuma commented on a change in pull request #10498:
URL: https://github.com/apache/kafka/pull/10498#discussion_r614068123
##
File path: core/src/main/scala/kafka/tools/DumpLogSegments.scala
##
@@ -279,8 +279,10 @@ object DumpLogSegments {
if (batch.magic >= Rec
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614066999
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serde/RemoteLogSegmentMetadataSerde.java
##
@@ -0,0 +1,87 @@
+/*
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614064785
##
File path: storage/src/main/resources/message/RemoteLogSegmentMetadata.json
##
@@ -0,0 +1,126 @@
+// Licensed to the Apache Software Foundation (ASF) u
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614031843
##
File path:
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serde/RemoteLogMetadataContextSerde.java
##
@@ -0,0 +1,115 @@
+/*
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614004395
##
File path:
storage/src/main/resources/message/RemoteLogSegmentMetadataUpdate.json
##
@@ -0,0 +1,83 @@
+// Licensed to the Apache Software Foundation (
satishd commented on a change in pull request #10271:
URL: https://github.com/apache/kafka/pull/10271#discussion_r614002154
##
File path: storage/src/main/resources/message/RemoteLogSegmentMetadata.json
##
@@ -0,0 +1,126 @@
+// Licensed to the Apache Software Foundation (ASF) u
showuon commented on pull request #10541:
URL: https://github.com/apache/kafka/pull/10541#issuecomment-820346080
Need to rework. Close it first.
--
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
showuon closed pull request #10541:
URL: https://github.com/apache/kafka/pull/10541
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17322092#comment-17322092
]
Alexis Polyzos commented on KAFKA-12635:
[~yangguo1220] thanks for the reply! We
[
https://issues.apache.org/jira/browse/KAFKA-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chun-Hao Tang reassigned KAFKA-12662:
-
Assignee: Chun-Hao Tang
> add unit test for ProducerPerformance
> -
mimaison commented on pull request #9549:
URL: https://github.com/apache/kafka/pull/9549#issuecomment-820299395
Not sure why the build had failed, I've rekicked it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
1 - 100 of 126 matches
Mail list logo
