Boyang Chen created KAFKA-10064:
---
Summary: Add documentation for KIP-571
Key: KAFKA-10064
URL: https://issues.apache.org/jira/browse/KAFKA-10064
Project: Kafka
Issue Type: Task
Compon
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119271#comment-17119271
]
Alex Sun commented on KAFKA-10036:
--
PR created: [https://github.com/apache/kafka/pull/8
sneakyburro opened a new pull request #8752:
URL: https://github.com/apache/kafka/pull/8752
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
https://stackove
ableegoldman commented on pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#issuecomment-635750374
call for review any of @guozhangwang @hachikuji @vvcephei
This is an automated message from the Apache Git S
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119261#comment-17119261
]
Sophie Blee-Goldman commented on KAFKA-9987:
Hey [~hai_lin] and [~twmb], I fi
ableegoldman commented on a change in pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#discussion_r432246028
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
##
@@ -425,8 +422,36 @@ public void te
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119257#comment-17119257
]
Alex Sun commented on KAFKA-10036:
--
Simplified version is:
Multiple ProcessorContext t
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119253#comment-17119253
]
Alex Sun commented on KAFKA-10036:
--
Hi [~mjsax], just to confirm the root cause. It is
ableegoldman commented on a change in pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#discussion_r432231137
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
##
@@ -582,35 +578,6 @@ public void
t
ableegoldman commented on a change in pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#discussion_r432230560
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/StickyAssignorTest.java
##
@@ -169,10 +169,10 @@ public void
testAssignmentWith
ijuma opened a new pull request #8751:
URL: https://github.com/apache/kafka/pull/8751
`./gradlew clean install` with gradle daemon reuse:
Gradle 6.4: `BUILD SUCCESSFUL in 2m 18s
Gradle 6.5-rc-1: `BUILD SUCCESSFUL in 1m 50s`
### Committer Checklist (excluded from commit messa
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-10038:
-
Assignee: Luke Chen
> ConsumerPerformance.scala supports the setting of client.id
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119210#comment-17119210
]
Luke Chen commented on KAFKA-10043:
---
hi [~tigertan], are you working on this issue? if
vitojeng commented on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-635718737
@mjsax Just rebase & force-pushed.
You can start review when you available.
This is an automated message from
showuon commented on pull request #8750:
URL: https://github.com/apache/kafka/pull/8750#issuecomment-635717082
hi @kkonstantine , I did some investigation for this flaky errors days ago,
but today, I found out you already fix it, and fix it with better way! Cool!
This is a small refacto
showuon opened a new pull request #8750:
URL: https://github.com/apache/kafka/pull/8750
1. Remove redundant `connect.stop();` since we'll do it after each test case
in `close()` function
2. Refine the error message to make it better explain the errors
### Committer Checklist (excl
ableegoldman commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635711087
Thanks! I actually don't think there ended up being anything relevant t o2.5
in the final form of this PR. Except maybe adding `@throws StreamsException` to
the `allLocalStor
vvcephei commented on pull request #8677:
URL: https://github.com/apache/kafka/pull/8677#issuecomment-635707062
Hey @abbccdda , I've just recently been in some investigation of these
timeouts as part of https://github.com/apache/kafka/pull/8738 , and we're also
planning to implement KIP-57
mjsax commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635706567
Merged to `trunk` and cherry-picked to `2.6`. Do we want this in `2.5`, too?
If yes, we would need a new PR. Not possible to cherry-pick.
--
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119197#comment-17119197
]
Adam Bellemare commented on KAFKA-10049:
Found the bug. The SubscriptionWrapperS
ijuma commented on a change in pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#discussion_r432209283
##
File path: core/src/test/scala/unit/kafka/network/SocketServerTest.scala
##
@@ -1886,19 +1926,13 @@ class SocketServerTest {
super.channels.forEac
vitojeng edited a comment on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-635703849
> Hey @vitojeng -- sorry for the long delay... We had a big KIP review back
log...
@mjsax Never mind, I understand. :)
I'll be rebase master again and update this
vitojeng commented on pull request #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-635703849
> Hey @vitojeng -- sorry for the long delay... We had a big KIP review back
log...
Never mind, I understand. :)
I'll be rebase master again and update this PR ASAP.
--
mjsax merged pull request #8738:
URL: https://github.com/apache/kafka/pull/8738
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 #8200:
URL: https://github.com/apache/kafka/pull/8200#issuecomment-635696040
Hey @vitojeng -- sorry for the long delay... We had a big KIP review back
log... I would dedicate review time now to get KIP-216 merged. Are you still
interested in pushing it over
ableegoldman commented on a change in pull request #8668:
URL: https://github.com/apache/kafka/pull/8668#discussion_r432200092
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -303,79 +469,17 @@ private int getBa
[
https://issues.apache.org/jira/browse/KAFKA-10057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119186#comment-17119186
]
qianrui commented on KAFKA-10057:
-
I know this parameter will be used in the future, but
hachikuji commented on a change in pull request #8739:
URL: https://github.com/apache/kafka/pull/8739#discussion_r432197918
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -345,7 +345,17 @@ synchronized boolean match
hachikuji commented on a change in pull request #8739:
URL: https://github.com/apache/kafka/pull/8739#discussion_r432197918
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -345,7 +345,17 @@ synchronized boolean match
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432190091
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -263,27 +259,28 @@ private v
[
https://issues.apache.org/jira/browse/KAFKA-10063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10063:
Description:
We have a few log cleaner metrics which iterate the set of cleaners. For
exa
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432185717
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterTopic(o
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432183678
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##
@@ -1468,9 +1456,6 @@ public void
shouldClos
hachikuji commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r432178706
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java
##
@@ -31,8 +37,21 @@
* @param isSimpleConsumerGroup I
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432178832
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
##
@@ -79,25 +88,27 @@
private static fina
vvcephei merged pull request #8748:
URL: https://github.com/apache/kafka/pull/8748
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
hachikuji opened a new pull request #8749:
URL: https://github.com/apache/kafka/pull/8749
We have seen this test failing from time to time. In spite of the low quota,
it is possible for one or more of the reassignments to complete before
verification that the reassignment is in progress. T
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432174885
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterT
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432171931
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
##
@@ -79,25 +88,27 @@
private static fina
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432172108
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -290,6 +295,8 @@ object TopicCommand extends Logging {
override def desc
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432171069
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterT
vvcephei commented on pull request #8747:
URL: https://github.com/apache/kafka/pull/8747#issuecomment-635659313
Thanks for the review, @abbccdda !
This is an automated message from the Apache Git Service.
To respond to the me
vvcephei commented on pull request #8747:
URL: https://github.com/apache/kafka/pull/8747#issuecomment-635659034
Java 11 build timed out.
This is an automated message from the Apache Git Service.
To respond to the message, ple
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432166896
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterT
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432166896
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterT
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432166675
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -223,8 +224,20 @@ class TopicCommandWithAdminClientTes
vinothchandar commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432164756
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -247,8 +247,12 @@ object TopicCommand extends Logging {
val createResu
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432162663
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -736,8 +743,8 @@ object TopicCommand extends Logging {
allTopicLevelOpts --
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432162663
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -736,8 +743,8 @@ object TopicCommand extends Logging {
allTopicLevelOpts --
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432162100
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -223,8 +224,20 @@ class TopicCommandWithAdminClientTest exte
mjsax commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635644144
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635644310
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432159935
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -324,7 +331,7 @@ object TopicCommand extends Logging {
override def deleteTopi
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432159364
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -290,6 +295,8 @@ object TopicCommand extends Logging {
override def describeTo
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432159364
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -290,6 +295,8 @@ object TopicCommand extends Logging {
override def describeTo
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432158637
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -259,7 +263,8 @@ object TopicCommand extends Logging {
override def alterTopic(o
ableegoldman commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432158766
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1246,7 +1246,7 @@ public void cleanUp() {
}
l
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432157321
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -247,8 +247,12 @@ object TopicCommand extends Logging {
val createResult =
cmccabe commented on a change in pull request #8737:
URL: https://github.com/apache/kafka/pull/8737#discussion_r432157321
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -247,8 +247,12 @@ object TopicCommand extends Logging {
val createResult =
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432155323
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -1247,4 +1270,33 @@ public void waitFor
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432155159
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
##
@@ -79,25 +88,27 @@
private static fina
mjsax commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635637908
Checkstyle error:
```
[ant:checkstyle] [ERROR]
/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk8-scala2.12/streams/src/test/java/org/apache/kafka/streams/processor/internals/
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432153623
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1246,7 +1246,7 @@ public void cleanUp() {
}
log.debu
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432153623
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1246,7 +1246,7 @@ public void cleanUp() {
}
log.debu
mjsax commented on a change in pull request #8706:
URL: https://github.com/apache/kafka/pull/8706#discussion_r432144610
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/QueryableStoreProvider.java
##
@@ -58,9 +58,21 @@ public QueryableStoreProvider(
mjsax commented on pull request #8706:
URL: https://github.com/apache/kafka/pull/8706#issuecomment-635633908
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635633587
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635633530
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
srpanwar-confluent commented on a change in pull request #8723:
URL: https://github.com/apache/kafka/pull/8723#discussion_r432148295
##
File path:
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
##
@@ -201,6 +201,13 @@ public String getString(String ke
srpanwar-confluent commented on a change in pull request #8723:
URL: https://github.com/apache/kafka/pull/8723#discussion_r432145568
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -2052,6 +2057,49 @@ void handleFailure(Throwable
ableegoldman commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r431571493
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java
##
@@ -90,24 +96,21 @@ public static String getTaskP
vvcephei commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432143143
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
##
@@ -79,25 +88,27 @@
private static final St
mjsax commented on pull request #8706:
URL: https://github.com/apache/kafka/pull/8706#issuecomment-635625227
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8706:
URL: https://github.com/apache/kafka/pull/8706#issuecomment-635625057
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
Jason Gustafson created KAFKA-10063:
---
Summary: UnsupportedOperation when querying cleaner metrics after
shutdown
Key: KAFKA-10063
URL: https://issues.apache.org/jira/browse/KAFKA-10063
Project: Kafk
mjsax commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-635616335
> Are you guys using some formatting tool
I use IntelliJ that does have some auto-formatting. Use it basically with
default settings. In doubt, disable auto-formatting to avoi
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432123361
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1246,7 +1247,12 @@ public void cleanUp() {
}
log.deb
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432123697
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -1246,7 +1247,12 @@ public void cleanUp() {
}
log.deb
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432121655
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java
##
@@ -45,42 +50,42 @@ public void
fetchEndOffsetsShou
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432121276
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java
##
@@ -79,25 +88,27 @@
private static fina
mjsax commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r432121258
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java
##
@@ -45,42 +50,42 @@ public void
fetchEndOffsetsShou
mimaison commented on pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#issuecomment-635604107
@hachikuji Thanks for the feedback. I've pushed updates addressing your
comments.
I've also updated the KIP accordingly and I'll send a message to the VOTE
thread on the m
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635603373
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635603479
\o/
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
vvcephei commented on pull request #8747:
URL: https://github.com/apache/kafka/pull/8747#issuecomment-635602993
The java 14 test failure is unrelated and fixed in
https://github.com/apache/kafka/pull/8748
This is an automate
vvcephei commented on pull request #8748:
URL: https://github.com/apache/kafka/pull/8748#issuecomment-635603081
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10062:
Labels: needs-kip (was: )
> Add a method to retrieve the current timestamp as known by th
vvcephei commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r432109207
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -1247,4 +1270,33 @@ public void waitForNext
ableegoldman opened a new pull request #8748:
URL: https://github.com/apache/kafka/pull/8748
Should go to 2.6
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
Piotr Smolinski created KAFKA-10062:
---
Summary: Add a method to retrieve the current timestamp as known
by the Streams app
Key: KAFKA-10062
URL: https://issues.apache.org/jira/browse/KAFKA-10062
Proj
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635589437
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10061:
Description:
We have seen this a few times:
{code}
org.scalatest.exceptions.TestFailedExce
Jason Gustafson created KAFKA-10061:
---
Summary: Flaky Test `ReassignPartitionsIntegrationTest
.testCancellation`
Key: KAFKA-10061
URL: https://issues.apache.org/jira/browse/KAFKA-10061
Project: Kafka
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635562805
I just resolved the conflicts.
This is an automated message from the Apache Git Service.
To respond to the messag
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635563117
... or not
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635562905
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
vvcephei commented on pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#issuecomment-635561957
Oh, actually @ableegoldman , it looks like there was a conflict with the
other PR I just merged.
This is an auto
vvcephei merged pull request #8743:
URL: https://github.com/apache/kafka/pull/8743
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-3468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119027#comment-17119027
]
Brad Schoening commented on KAFKA-3468:
---
Similar behavior occurs when security.prot
ijuma commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r432073518
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,11 @@ abstract class AbstractFetcherThread(name: String,
1 - 100 of 199 matches
Mail list logo
