showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638511262
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -67,7 +68,7 @@ public FileBasedStateStore(final File stateFile) {
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638513347
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
@Overri
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638519831
##
File path: core/src/main/scala/kafka/log/LogSegments.scala
##
@@ -210,11 +209,23 @@ class LogSegments(topicPartition: TopicPartition) {
* @return t
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638520142
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1217,10 +1213,8 @@ class Log(@volatile private var _dir: File,
fetchDataInfo = seg
kowshik commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638520142
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1217,10 +1213,8 @@ class Log(@volatile private var _dir: File,
fetchDataInfo = seg
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350859#comment-17350859
]
Josep Prat commented on KAFKA-12824:
I know that some of the ones I created might no
[
https://issues.apache.org/jira/browse/KAFKA-12822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350862#comment-17350862
]
Josep Prat commented on KAFKA-12822:
As [~mjsax] pointed out, some of this sub-tasks
kowshik opened a new pull request #10756:
URL: https://github.com/apache/kafka/pull/10756
Have done a small improvement in this PR by flipping logical NOT for
readability. Basically, the following code:
```
if (A) {
if (B) {
} else {
}
} else if (B) {
}
```
kowshik commented on pull request #10756:
URL: https://github.com/apache/kafka/pull/10756#issuecomment-847620694
cc @junrao @ijuma @chia7712 for review
--
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
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638535599
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch logEndOffsetAndEpoch)
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638536001
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,17 @@ private QuorumStateData readStateFromFile(File file
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638537574
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
@Overri
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638535599
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch logEndOffsetAndEpoch)
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638542037
##
File path: raft/src/main/java/org/apache/kafka/raft/QuorumState.java
##
@@ -116,7 +117,7 @@ public void initialize(OffsetAndEpoch logEndOffsetAndEpoch)
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638542877
##
File path: raft/src/test/java/org/apache/kafka/raft/QuorumStateTest.java
##
@@ -945,9 +945,7 @@ public void testObserverUnattachedToFollower() throws
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638544356
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
@Overri
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847644863
hi @showuon, can you please review this for me?
Many thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638556812
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -372,27 +371,23 @@ private void maybeFireLeaderChange() {
@Overri
showuon commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847654763
@DuongPTIT , thanks for the PR. One important question to you before
reviewing the code: could you confirm this issue only happen in V2.5, and not
V2.8? I'm not sure if we will
yws created KAFKA-12846:
---
Summary: why need this logic in Consumer‘s Fetch logic it should
remove?
Key: KAFKA-12846
URL: https://issues.apache.org/jira/browse/KAFKA-12846
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-12846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350904#comment-17350904
]
Luke Chen commented on KAFKA-12846:
---
[~ws], I believe the comments in else block answe
kowshik closed pull request #9764:
URL: https://github.com/apache/kafka/pull/9764
--
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
[
https://issues.apache.org/jira/browse/KAFKA-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-10900:
--
Assignee: loboxu
> Add metrics enumerated in KIP-630
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12461:
--
Assignee: (was: loboxu)
> Extend LogManager to cover the metadata topic
> ---
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847728426
> Please confirm if the issue only happen in V2.5 or newer release. If also
happen in trunk, please make the merge target as `trunk` (and fix based on the
`trunk` branch), and
DuongPTIT removed a comment on pull request #10670:
URL: https://github.com/apache/kafka/pull/10670#issuecomment-840464740
--
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.
F
DuongPTIT commented on pull request #10670:
URL: https://github.com/apache/kafka/pull/10670#issuecomment-847730974
hi @showuon, please take a review. Thank you so much!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350941#comment-17350941
]
Bruno Cadonna commented on KAFKA-12824:
---
[~mjsax] Do we know for which date AK 4.0
[
https://issues.apache.org/jira/browse/KAFKA-12824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350942#comment-17350942
]
Josep Prat commented on KAFKA-12824:
On the parent issue there is this sentence:
>
DuongPTIT edited a comment on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847728426
> Please confirm if the issue only happen in V2.5 or newer release. If also
happen in trunk, please make the merge target as `trunk` (and fix based on the
`trunk` branc
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638651011
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -444,23 +392,32 @@ private boolean allS
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638654728
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -469,73 +426,190 @@ private boolean all
tombentley commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847746044
Probably fixed by https://github.com/apache/kafka/pull/9735
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638655936
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -637,19 +709,27 @@ private void assignP
dengziming commented on pull request #10701:
URL: https://github.com/apache/kafka/pull/10701#issuecomment-847753120
@mjsax @guozhangwang , how do you think about this approach? In fact, I'm
not very confident about this change since it isn't very elegant, but this can
remove the TODO, feel
DuongPTIT commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847756554
> Probably fixed by #9735
I've seen that this issue still happen in V2.5, V2.6, V2.7. What about these
versions? Do they need to fix this similar to V2.8 and trunk?
[
https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350960#comment-17350960
]
Bruno Cadonna commented on KAFKA-5676:
--
[~marcolotz] Thank you for looking into this
[
https://issues.apache.org/jira/browse/KAFKA-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350960#comment-17350960
]
Bruno Cadonna edited comment on KAFKA-5676 at 5/25/21, 10:42 AM:
--
rajinisivaram commented on pull request #10377:
URL: https://github.com/apache/kafka/pull/10377#issuecomment-847762942
@feyman2016 We should add `ignorable=true` for the fields added for feature
support in
`clients/src/main/resources/common/message/ApiVersionsResponse.json`. This
would av
Abhijit Mane created KAFKA-12847:
Summary: Dockerfile needed for kafka system tests needs changes
Key: KAFKA-12847
URL: https://issues.apache.org/jira/browse/KAFKA-12847
Project: Kafka
Issue
tombentley commented on pull request #10750:
URL: https://github.com/apache/kafka/pull/10750#issuecomment-847768625
It's unlikely that 2.5 or 2.6 will see another release, but I've backported
it to the 2.7 branch so it's in any 2.7.2 which gets released.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-10846:
Fix Version/s: 2.7.2
> FileStreamSourceTask buffer can grow without bound
> --
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
([https://github
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
(_[https://githu
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
([https://github
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
([https://github
[
https://issues.apache.org/jira/browse/KAFKA-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhijit Mane updated KAFKA-12847:
-
Description:
Hello,
I tried apache/kafka system tests as per documentation: -
([https://github
[
https://issues.apache.org/jira/browse/KAFKA-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat reassigned KAFKA-12782:
--
Assignee: Josep Prat
> Javadocs search sends you to a non-existent URL
>
[
https://issues.apache.org/jira/browse/KAFKA-12743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351000#comment-17351000
]
Sergey Zyrianov commented on KAFKA-12743:
-
I don't think uReplicator alternative
[
https://issues.apache.org/jira/browse/KAFKA-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351001#comment-17351001
]
Josep Prat commented on KAFKA-12782:
I can confirm this is bug with Java11 for API d
dajac opened a new pull request #10757:
URL: https://github.com/apache/kafka/pull/10757
This patch logs more information when a producer snapshot is written to the
disk.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638718719
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -637,19 +709,27 @@ private void assignP
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-847807953
@vahidhashemian , thanks for the comments. I've updated. Please take a look
again. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the me
jlprat opened a new pull request #10758:
URL: https://github.com/apache/kafka/pull/10758
This is just a workaround to solve this problem while we are still using
JDK11.
Once moving to, presumably, JDK17 this change won't be needed
anymore and could be deleted safely. See
https://bu
jlprat commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-847839591
cc @ableegoldman as you opened the Jira ticket, maybe you'd like to review
this one?
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
dajac commented on a change in pull request #10616:
URL: https://github.com/apache/kafka/pull/10616#discussion_r638764893
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/internals/AllBrokersStrategy.java
##
@@ -0,0 +1,212 @@
+/*
+ * Licensed to the Apache So
dajac merged pull request #10717:
URL: https://github.com/apache/kafka/pull/10717
--
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
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-12800:
---
Assignee: (was: David Jacot)
> Configure jackson to to reject trailing input in the gen
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-12800:
---
Assignee: David Jacot
> Configure jackson to to reject trailing input in the generator
> --
[
https://issues.apache.org/jira/browse/KAFKA-12800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-12800.
-
Fix Version/s: 3.0.0
Resolution: Fixed
Author: Nathan Lincoln
> Configure jackson to to
ijuma opened a new pull request #10759:
URL: https://github.com/apache/kafka/pull/10759
New parameters in overloaded methods should appear later apart from
lambdas that should always be last.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implemen
thomaskwscott opened a new pull request #10760:
URL: https://github.com/apache/kafka/pull/10760
See
https://cwiki.apache.org/confluence/display/KAFKA/KIP-734%3A+Improve+AdminClient.listOffsets+to+return+timestamp+and+offset+for+the+record+with+the+largest+timestamp
*More detailed des
ijuma opened a new pull request #10761:
URL: https://github.com/apache/kafka/pull/10761
Log if deletion fails and don't expose log topic id for mutability outside
of `assignTopicId()`.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
ijuma commented on pull request #10761:
URL: https://github.com/apache/kafka/pull/10761#issuecomment-847881296
cc @jolshan
--
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.
dajac commented on pull request #10760:
URL: https://github.com/apache/kafka/pull/10760#issuecomment-847883470
I will review it in the next few days.
--
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
ijuma commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638803061
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
config.mess
dongjinleekr commented on pull request #10428:
URL: https://github.com/apache/kafka/pull/10428#issuecomment-847885818
Rebased onto the latest trunk. cc/ @cadonna
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
dongjinleekr commented on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-847886290
Hi @guozhangwang @vvcephei,
Could you have a look now? :smiley:
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dajac commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638806738
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
config.mess
mdedetrich opened a new pull request #10762:
URL: https://github.com/apache/kafka/pull/10762
This PR does various QoL improvements for the MM tests, mainly some basic
refactoring to remove some boilerplate as well as adding messages to all of the
assert statements so that if they fail ther
ryannedolan commented on pull request #10762:
URL: https://github.com/apache/kafka/pull/10762#issuecomment-847906780
thx lgtm!
--
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 commen
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351093#comment-17351093
]
Matthew de Detrich commented on KAFKA-12430:
[~ryannedolan] I am going to lo
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthew de Detrich reassigned KAFKA-12430:
--
Assignee: Matthew de Detrich
> emit.heartbeats.enabled = false should disable
ijuma commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638837477
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
config.mess
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351104#comment-17351104
]
Ryanne Dolan commented on KAFKA-12430:
--
Hmm. I guess the downside to not creating t
dajac commented on a change in pull request #10757:
URL: https://github.com/apache/kafka/pull/10757#discussion_r638898378
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2011,7 +2011,11 @@ object Log extends Logging {
logDirFailureChannel,
config.mess
[
https://issues.apache.org/jira/browse/KAFKA-9009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351155#comment-17351155
]
Josep Prat commented on KAFKA-9009:
---
Seen in
[https://ci-builds.apache.org/job/Kafka/j
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351159#comment-17351159
]
Josep Prat commented on KAFKA-12511:
Seen in:
[https://ci-builds.apache.org/job/Kaf
[
https://issues.apache.org/jira/browse/KAFKA-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351161#comment-17351161
]
Josep Prat commented on KAFKA-12319:
Failed again in
[https://ci-builds.apache.org/
[
https://issues.apache.org/jira/browse/KAFKA-12511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351159#comment-17351159
]
Josep Prat edited comment on KAFKA-12511 at 5/25/21, 4:00 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351166#comment-17351166
]
Josep Prat commented on KAFKA-9295:
---
Seen it in
[https://ci-builds.apache.org/job/Kafk
jlprat commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-847997038
Test failures were known flaky tests. Added a comment on the corresponding
Jira's
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351227#comment-17351227
]
Pedro Gontijo commented on KAFKA-12845:
---
[~mjsax] and [~JoelWee] it would be great
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351227#comment-17351227
]
Pedro Gontijo edited comment on KAFKA-12845 at 5/25/21, 5:26 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351227#comment-17351227
]
Pedro Gontijo edited comment on KAFKA-12845 at 5/25/21, 5:26 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351230#comment-17351230
]
Sagar Rao commented on KAFKA-9168:
--
[~ableegoldman], so I went through the github PR lin
[
https://issues.apache.org/jira/browse/KAFKA-8295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351232#comment-17351232
]
Sagar Rao commented on KAFKA-8295:
--
hey [~ableegoldman], wanted to know if you got a cha
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351238#comment-17351238
]
A. Sophie Blee-Goldman commented on KAFKA-9168:
---
Yep, I think that's exactl
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351243#comment-17351243
]
Sagar Rao commented on KAFKA-9168:
--
Got it.. How do you want me to benchmark? Using the
ableegoldman commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-848103904
To be honest I don't have much context on the javadocs but I will take a
look. Maybe @ijuma can help review
--
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/KAFKA-9295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-9295:
---
Guess there is still something else going on here yet. At this point I think we
jlprat commented on pull request #10758:
URL: https://github.com/apache/kafka/pull/10758#issuecomment-848155893
Sure @ableegoldman , no worries. I just mentioned you as you were the one
who created the ticket.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351308#comment-17351308
]
Matthias J. Sax commented on KAFKA-12845:
-
I think you confuse "input record key
ccding opened a new pull request #10763:
URL: https://github.com/apache/kafka/pull/10763
When we find a .swap file on startup, we typically want to rename and
replace it as .log, .index, .timeindex, etc. as a way to complete any ongoing
replace operations. These swap files are usually know
A. Sophie Blee-Goldman created KAFKA-12848:
--
Summary: Add some basic benchmarks for Kafka Streams
Key: KAFKA-12848
URL: https://issues.apache.org/jira/browse/KAFKA-12848
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351377#comment-17351377
]
A. Sophie Blee-Goldman commented on KAFKA-9168:
---
There's nothing available
junrao commented on a change in pull request #10280:
URL: https://github.com/apache/kafka/pull/10280#discussion_r638367249
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1500,50 +1325,67 @@ class Log(@volatile private var _dir: File,
}
}
-deleteO
DuongPTIT removed a comment on pull request #10677:
URL: https://github.com/apache/kafka/pull/10677#issuecomment-845827053
@chia7712 PTAL, thanks!
--
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
DuongPTIT commented on pull request #10677:
URL: https://github.com/apache/kafka/pull/10677#issuecomment-848382648
hi @showuon, can you please review this issue for me? Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
mjsax commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r639338584
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional timeCurrentIdl
1 - 100 of 117 matches
Mail list logo
