dajac commented on a change in pull request #9630:
URL: https://github.com/apache/kafka/pull/9630#discussion_r534900872
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java
##
@@ -1839,20 +1839,17 @@ private OffsetsForLeaderEpochRespons
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241383#comment-17241383
]
zhangzhisheng edited comment on KAFKA-3042 at 12/3/20, 8:25 AM:
---
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241383#comment-17241383
]
zhangzhisheng edited comment on KAFKA-3042 at 12/3/20, 8:26 AM:
---
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r534909816
##
File path: clients/src/main/resources/common/message/LeaderChangeMessage.json
##
@@ -22,7 +22,11 @@
{"name": "LeaderId", "type": "int32", "vers
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241383#comment-17241383
]
zhangzhisheng edited comment on KAFKA-3042 at 12/3/20, 8:27 AM:
---
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r534911206
##
File path: raft/src/main/java/org/apache/kafka/raft/LeaderState.java
##
@@ -72,11 +73,20 @@ public int epoch() {
return voterReplicaStates.
[
https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-10801:
Fix Version/s: 2.7.0
> Docs on configuration have multiple places using the same HTML anchor tag
>
[
https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243009#comment-17243009
]
Tom Bentley commented on KAFKA-10801:
-
This has been fixed in Kafka 2.7, see
https:
[
https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley resolved KAFKA-10801.
-
Resolution: Fixed
> Docs on configuration have multiple places using the same HTML anchor tag
>
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243023#comment-17243023
]
Christian Duvholt commented on KAFKA-10417:
---
[~lct45] unfortunately I'm not ab
d8tltanc commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r534983615
##
File path:
core/src/test/scala/unit/kafka/security/authorizer/AclAuthorizerTest.scala
##
@@ -82,16 +86,17 @@ class AclAuthorizerTest extends ZooKeeperT
lmr3796 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r535019810
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1243,19 +1244,30 @@ class KafkaApis(val requestChannel: RequestChannel,
topicRe
lmr3796 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r535019810
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1243,19 +1244,30 @@ class KafkaApis(val requestChannel: RequestChannel,
topicRe
tombentley commented on pull request #9676:
URL: https://github.com/apache/kafka/pull/9676#issuecomment-737815296
@hachikuji thanks for taking a look, I've fixed the test failures. Do we
also need something on the read path, KAFKA-10778 suggested so?
--
[
https://issues.apache.org/jira/browse/KAFKA-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243069#comment-17243069
]
Mickael Maison commented on KAFKA-10566:
Is this a DUP of https://issues.apache.
Mickael Maison created KAFKA-10802:
--
Summary: Spurious log message when starting consumers
Key: KAFKA-10802
URL: https://issues.apache.org/jira/browse/KAFKA-10802
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison updated KAFKA-10802:
---
Description:
Reported by Gary Russell in the [2.6.1 RC3 vote
thread|https://lists.apache.or
rajinisivaram commented on pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#issuecomment-737825503
@hachikuji Thanks for all your help and patience in reviewing this PR!
Merging to trunk.
This is an automa
rajinisivaram merged pull request #9382:
URL: https://github.com/apache/kafka/pull/9382
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
[
https://issues.apache.org/jira/browse/KAFKA-10554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-10554.
Reviewer: Jason Gustafson
Resolution: Fixed
> Perform follower truncation based on e
[
https://issues.apache.org/jira/browse/KAFKA-10801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243078#comment-17243078
]
James Cheng commented on KAFKA-10801:
-
Thanks [~tombentley]!
I just looked it up
[
https://issues.apache.org/jira/browse/KAFKA-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley resolved KAFKA-10566.
-
Resolution: Duplicate
> Erroneous unknown config warnings about ssl and sasl configs
> -
[
https://issues.apache.org/jira/browse/KAFKA-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243088#comment-17243088
]
Tom Bentley commented on KAFKA-10566:
-
Yes.
> Erroneous unknown config warnings abo
tombentley closed pull request #9365:
URL: https://github.com/apache/kafka/pull/9365
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
mimaison commented on pull request #9326:
URL: https://github.com/apache/kafka/pull/9326#issuecomment-737854381
Thanks for the update. The changes looks fine.
I've rekicked the build and I'll merge if it passes
This is an
mimaison edited a comment on pull request #9326:
URL: https://github.com/apache/kafka/pull/9326#issuecomment-737854381
Thanks for the update. The changes look fine.
I've rekicked the build and I'll merge if it passes
This
lqjack commented on pull request #9675:
URL: https://github.com/apache/kafka/pull/9675#issuecomment-737874013
@chia7712 does the patch can resolve the issue ? I find the only
differences is that controllerContext.allPartitions can be invoked once or the
number of partition times . please
dajac commented on pull request #9630:
URL: https://github.com/apache/kafka/pull/9630#issuecomment-737897424
I just rebased the PR and it had conflicts with
7ecc3a579a4b13e0cef4bd3129982ea3bc1a9341.
This is an automated mess
dajac edited a comment on pull request #9630:
URL: https://github.com/apache/kafka/pull/9630#issuecomment-737897424
I just rebased the PR cause it had conflicts with
7ecc3a579a4b13e0cef4bd3129982ea3bc1a9341.
This is an autom
mimaison commented on a change in pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#discussion_r535095426
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -0,0 +1,617 @@
+/*
+
mumrah commented on a change in pull request #9677:
URL: https://github.com/apache/kafka/pull/9677#discussion_r535210273
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1406,10 +1429,13 @@ class Partition(val topicPartition: TopicPartition,
case
APaMio opened a new pull request #9680:
URL: https://github.com/apache/kafka/pull/9680
MINOR PR Test
@chia7712
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
chia7712 commented on pull request #9680:
URL: https://github.com/apache/kafka/pull/9680#issuecomment-738020123
@APaMio Thanks for your patch. Could you revise the title? The “caee2” is a
bit weird to me :)
This is an automa
[
https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leah Thomas reassigned KAFKA-10417:
---
Assignee: Leah Thomas
> suppress() with cogroup() throws ClassCastException
> -
mimaison commented on pull request #9326:
URL: https://github.com/apache/kafka/pull/9326#issuecomment-738032602
Travis/Jenkins are having issues. I ran all tests locally and they passed.
This is an automated message from the
mimaison merged pull request #9326:
URL: https://github.com/apache/kafka/pull/9326
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-10460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-10460.
Fix Version/s: 2.8.0
Resolution: Fixed
> ReplicaListValidator format checking is in
cadonna opened a new pull request #9681:
URL: https://github.com/apache/kafka/pull/9681
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade
cadonna commented on pull request #9681:
URL: https://github.com/apache/kafka/pull/9681#issuecomment-738054912
Call for review: @vvcephei @ableegoldman @guozhangwang
This is an automated message from the Apache Git Service.
cadonna commented on a change in pull request #9681:
URL: https://github.com/apache/kafka/pull/9681#discussion_r535310939
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegrationTest.java
##
@@ -136,13 +136,13 @@ public void
shouldQueryOn
ijuma commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r535321971
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1243,19 +1244,30 @@ class KafkaApis(val requestChannel: RequestChannel,
topicResp
[
https://issues.apache.org/jira/browse/KAFKA-7588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243261#comment-17243261
]
Ismael Juma commented on KAFKA-7588:
Seems like the PR was merged, so this Jira shoul
[
https://issues.apache.org/jira/browse/KAFKA-10802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243273#comment-17243273
]
Gary Russell commented on KAFKA-10802:
--
Also
>I am not sure I understand why it's
ning2008wisc commented on pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#issuecomment-738115781
https://github.com/apache/kafka/pull/9224#discussion_r535179359
I think the `try catch` block is needed for several Exception.
```
/kafka/connect/mirror/src/t
Prateek Agarwal created KAFKA-10803:
---
Summary: Skip improper dynamic configs while initialization and
include the rest correct ones
Key: KAFKA-10803
URL: https://issues.apache.org/jira/browse/KAFKA-10803
junrao commented on pull request #7884:
URL: https://github.com/apache/kafka/pull/7884#issuecomment-738119273
@wushujames : This PR is mostly ready. It's just waiting for another
committer more familiar with the transactional logic to take another look.
@ConcurrencyPractitioner : Wou
prat0318 opened a new pull request #9682:
URL: https://github.com/apache/kafka/pull/9682
There is [a
bug](https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/DynamicBrokerConfig.scala#L470)
in how incorrect dynamic config keys are removed from the original Propertie
ning2008wisc commented on a change in pull request #9224:
URL: https://github.com/apache/kafka/pull/9224#discussion_r535386444
##
File path:
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java
##
@@ -0,0 +1,617 @@
+
prat0318 commented on a change in pull request #9682:
URL: https://github.com/apache/kafka/pull/9682#discussion_r535387403
##
File path: core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
##
@@ -400,6 +400,33 @@ class DynamicBrokerConfigTest {
newprops.put
dajac commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r535387504
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -56,11 +56,12 @@ import scala.collection._
* --entity-type
dajac commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r535388027
##
File path: core/src/main/scala/kafka/server/AdminManager.scala
##
@@ -920,32 +954,49 @@ class AdminManager(val config: KafkaConfig,
!name.isDefine
[
https://issues.apache.org/jira/browse/KAFKA-10803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243320#comment-17243320
]
Prateek Agarwal commented on KAFKA-10803:
-
PR: https://github.com/apache/kafka/p
splett2 commented on a change in pull request #9628:
URL: https://github.com/apache/kafka/pull/9628#discussion_r535397962
##
File path: core/src/main/scala/kafka/admin/ConfigCommand.scala
##
@@ -56,11 +56,12 @@ import scala.collection._
* --entity-typ
cadonna commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r535383909
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +900,75 @@ private KafkaStreams(final InternalTopologyBuilder
chia7712 commented on pull request #9675:
URL: https://github.com/apache/kafka/pull/9675#issuecomment-738140790
@lqjack good question!
> I find the only differences is that controllerContext.allPartitions can
be invoked once or the number of partition times .
```controllerCon
chia7712 commented on a change in pull request #9682:
URL: https://github.com/apache/kafka/pull/9682#discussion_r535428840
##
File path: core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala
##
@@ -400,6 +400,33 @@ class DynamicBrokerConfigTest {
newprops.put
prat0318 commented on a change in pull request #9682:
URL: https://github.com/apache/kafka/pull/9682#discussion_r535442782
##
File path: core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
##
@@ -467,7 +467,9 @@ class DynamicBrokerConfig(private val kafkaConfig:
KafkaCo
dajac commented on pull request #9630:
URL: https://github.com/apache/kafka/pull/9630#issuecomment-738174240
Test failure is unrelated:
* Build / JDK 8 / kafka.api.TransactionsTest.testBumpTransactionalEpoch
This is an aut
dajac merged pull request #9630:
URL: https://github.com/apache/kafka/pull/9630
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-10739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10739.
-
Resolution: Done
> Replace EpochEndOffset with automated protocol
>
hachikuji commented on a change in pull request #9677:
URL: https://github.com/apache/kafka/pull/9677#discussion_r535452252
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1403,7 +1426,9 @@ class Partition(val topicPartition: TopicPartition,
}
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r535468574
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +900,75 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r535471146
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +900,75 @@ private KafkaStreams(final InternalTopologyBuilder
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r535474040
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundati
[
https://issues.apache.org/jira/browse/KAFKA-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-10777:
--
Labels: mirror mirror-maker mirrormaker (was: )
> Add additional configuration to control MM2
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r535477229
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +900,75 @@ private KafkaStreams(final InternalTopologyBuilder
[
https://issues.apache.org/jira/browse/KAFKA-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-10777:
-
Assignee: Omnia Ibrahim
> Add additional configuration to control MM2 internal topics n
[
https://issues.apache.org/jira/browse/KAFKA-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-10777:
--
Summary: Add additional configuration to control MirrorMaker2 internal
topics naming conventio
[
https://issues.apache.org/jira/browse/KAFKA-10777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim updated KAFKA-10777:
--
Summary: Add additional configuration to control MirrorMaker 2 internal
topics naming conventi
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r535482262
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java
##
@@ -74,18 +74,19 @@ public void freeze() throws IOException {
lmr3796 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r535489887
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1243,19 +1244,30 @@ class KafkaApis(val requestChannel: RequestChannel,
topicRe
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241113#comment-17241113
]
James Galasyn edited comment on KAFKA-2967 at 12/3/20, 6:53 PM:
---
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r535503453
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -870,43 +900,75 @@ private KafkaStreams(final InternalTopologyBuilder
mjsax commented on pull request #9614:
URL: https://github.com/apache/kafka/pull/9614#issuecomment-738231066
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan commented on KAFKA-10774:
I've updated the KIP to add another met
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan edited comment on KAFKA-10774 at 12/3/20, 7:14 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan edited comment on KAFKA-10774 at 12/3/20, 7:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan edited comment on KAFKA-10774 at 12/3/20, 7:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan edited comment on KAFKA-10774 at 12/3/20, 7:15 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243454#comment-17243454
]
Justine Olshan edited comment on KAFKA-10774 at 12/3/20, 7:16 PM:
guozhangwang commented on a change in pull request #9276:
URL: https://github.com/apache/kafka/pull/9276#discussion_r535511409
##
File path: docs/ops.html
##
@@ -1129,6 +1128,26 @@ Security
Considerations for Remote Mon
kafka.server:type=BrokerTopicMetrics,name=Reass
guozhangwang merged pull request #9276:
URL: https://github.com/apache/kafka/pull/9276
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
Jason Gustafson created KAFKA-10804:
---
Summary: Tune travis system tests to avoid timeouts
Key: KAFKA-10804
URL: https://issues.apache.org/jira/browse/KAFKA-10804
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243458#comment-17243458
]
Jason Gustafson commented on KAFKA-10804:
-
cc [~chia7712]
> Tune travis system
Jason Gustafson created KAFKA-10805:
---
Summary: More useful reporting from travis system tests
Key: KAFKA-10805
URL: https://issues.apache.org/jira/browse/KAFKA-10805
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-10805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243461#comment-17243461
]
Jason Gustafson commented on KAFKA-10805:
-
cc [~chia7712]
> More useful reporti
[
https://issues.apache.org/jira/browse/KAFKA-10555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Walker Carlson reassigned KAFKA-10555:
--
Assignee: Walker Carlson
> Improve client state machine
> ---
JimGalasyn opened a new pull request #9683:
URL: https://github.com/apache/kafka/pull/9683
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
mjsax merged pull request #9683:
URL: https://github.com/apache/kafka/pull/9683
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the
mjsax commented on pull request #9683:
URL: https://github.com/apache/kafka/pull/9683#issuecomment-738284048
Merged to `trunk` and cherry-picked to `2.7` and `2.6` branches.
This is an automated message from the Apache Git Se
ijuma commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r535572033
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation
ijuma commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r535574184
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotWriter.java
##
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation
bbejeck commented on pull request #9674:
URL: https://github.com/apache/kafka/pull/9674#issuecomment-738292594
Java 11 failed with
```
> Task :streams:streams-scala:integrationTest FAILED
05:26:47 org.gradle.internal.remote.internal.ConnectException: Could not
connect to server [
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243500#comment-17243500
]
Matthias J. Sax commented on KAFKA-2967:
Btw: [https://infra.apache.org/project-s
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243503#comment-17243503
]
John Roesler commented on KAFKA-2967:
-
Hi [~JimGalasyn] ,
Thanks for that informatio
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243502#comment-17243502
]
James Galasyn commented on KAFKA-2967:
--
[~mjsax] Very cool, thank you for the tip!
mumrah commented on pull request #9677:
URL: https://github.com/apache/kafka/pull/9677#issuecomment-738303699
Failed tests are known flaky
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-9677/8/
