[
https://issues.apache.org/jira/browse/KAFKA-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andre Araujo updated KAFKA-10048:
-
Flags: (was: Patch)
> Possible data gap for a consumer after a failover when using MM2
> -
[
https://issues.apache.org/jira/browse/KAFKA-10048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andre Araujo updated KAFKA-10048:
-
Flags: Patch
> Possible data gap for a consumer after a failover when using MM2
> --
Amit Chauhan created KAFKA-10049:
Summary: KTable-KTable Foreign
Key: KAFKA-10049
URL: https://issues.apache.org/jira/browse/KAFKA-10049
Project: Kafka
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Chauhan updated KAFKA-10049:
-
Description:
I want to make use of _KTable-KTable_ join feature released in *_2.5.0_* but
faci
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Chauhan updated KAFKA-10049:
-
Description:
I want to make use of _KTable-KTable_ join feature released in *_2.5.0_* but
faci
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117509#comment-17117509
]
Mateusz Jadczyk commented on KAFKA-9891:
[~mjsax] If I'm not mistaken, these logs
Nikolay Izhikov created KAFKA-10050:
---
Summary: kafka_log4j_appender.py broken on JDK11
Key: KAFKA-10050
URL: https://issues.apache.org/jira/browse/KAFKA-10050
Project: Kafka
Issue Type: Bug
nizhikov opened a new pull request #8731:
URL: https://github.com/apache/kafka/pull/8731
kafka_log4j_appender.py broken on JDK11 by
#befd80b38d3ccb1aa0c6d99a899129fd5cf27774
This fix just setup node version for log4j appender.
### Committer Checklist (excluded from commit message)
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amit Chauhan updated KAFKA-10049:
-
Description:
I want to make use of _KTable-KTable_ Foreign Key join feature released in
*_2.5.
viktorsomogyi commented on a change in pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#discussion_r430997918
##
File path: core/src/main/scala/kafka/utils/Json.scala
##
@@ -65,6 +63,16 @@ object Json {
catch { case e: JsonProcessingException => Left(e) }
viktorsomogyi commented on a change in pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#discussion_r430997918
##
File path: core/src/main/scala/kafka/utils/Json.scala
##
@@ -65,6 +63,16 @@ object Json {
catch { case e: JsonProcessingException => Left(e) }
viktorsomogyi commented on a change in pull request #4090:
URL: https://github.com/apache/kafka/pull/4090#discussion_r431001766
##
File path: core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
##
@@ -1609,14 +1610,15 @@ object ReassignPartitionsCommand extends Logg
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431001869
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +33,15 @@ import scala.math.{max, min}
*/
private[group] class
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431002494
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +33,15 @@ import scala.math.{max, min}
*/
private[group] class
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431003374
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +33,15 @@ import scala.math.{max, min}
*/
private[group] class
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117609#comment-17117609
]
Marouane RAJI commented on KAFKA-4090:
--
Hey,
We ran into this issue with Samza job
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117609#comment-17117609
]
Marouane RAJI edited comment on KAFKA-4090 at 5/27/20, 10:11 AM:
--
Stefan Zwanenburg created KAFKA-10051:
-
Summary: kafka_2.11 2.5.0 isn't available on Maven Central
Key: KAFKA-10051
URL: https://issues.apache.org/jira/browse/KAFKA-10051
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Sun reassigned KAFKA-10036:
Assignee: Alex Sun
> Improve error message if user violates `Supplier` pattern
>
tombentley commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-634585597
Rebased for conflict.
@kkonstantine I've addressed those first comments, thanks! Still some work
on the integration test (not passing when run via gradle).
[
https://issues.apache.org/jira/browse/KAFKA-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley resolved KAFKA-10051.
-
Resolution: Won't Fix
Kafka 2.5.0 dropped support for Scala 2.11.
> kafka_2.11 2.5.0 isn't avai
[
https://issues.apache.org/jira/browse/KAFKA-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117661#comment-17117661
]
Stefan Zwanenburg commented on KAFKA-10051:
---
Ah. The release notes mentioned a
[
https://issues.apache.org/jira/browse/KAFKA-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117673#comment-17117673
]
Nikolay Izhikov commented on KAFKA-10050:
-
Results with the patch:
{noformat}
ni
nizhikov commented on pull request #8731:
URL: https://github.com/apache/kafka/pull/8731#issuecomment-634599948
Hello, @ijuma
I found that `kafka_log4j_appender.py` broken for JDK11.
This was broken by my patch - befd80b38d3ccb1aa0c6d99a899129fd5cf27774
I've prepared onelin
ijuma commented on pull request #8728:
URL: https://github.com/apache/kafka/pull/8728#issuecomment-634623654
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
ijuma commented on pull request #8726:
URL: https://github.com/apache/kafka/pull/8726#issuecomment-634638112
Unrelated test failures.
This is an automated message from the Apache Git Service.
To respond to the message, please
ijuma merged pull request #8726:
URL: https://github.com/apache/kafka/pull/8726
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
ijuma commented on pull request #8731:
URL: https://github.com/apache/kafka/pull/8731#issuecomment-634644538
Thanks for the PR. Can you elaborate how the original change broke it? I
don't see anything obviously related.
This
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117750#comment-17117750
]
Ella Kurginyan commented on KAFKA-7500:
---
Hi [~ryannedolan]. Now I can't find class
nizhikov commented on pull request #8731:
URL: https://github.com/apache/kafka/pull/8731#issuecomment-634652827
I added call of `fix_opts_for_new_jvm`
[here](https://github.com/apache/kafka/commit/befd80b38d3ccb1aa0c6d99a899129fd5cf27774#diff-ad7ee04aff5cb79b1478d038d59d4bbeR48).
But
nizhikov edited a comment on pull request #8731:
URL: https://github.com/apache/kafka/pull/8731#issuecomment-634652827
I added call of `fix_opts_for_new_jvm`
[here](https://github.com/apache/kafka/commit/befd80b38d3ccb1aa0c6d99a899129fd5cf27774#diff-ad7ee04aff5cb79b1478d038d59d4bbeR48).
[
https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117760#comment-17117760
]
Raman Gupta commented on KAFKA-10007:
-
It certainly could be. I'm not certain KAFKA-
wj1918 commented on pull request #2880:
URL: https://github.com/apache/kafka/pull/2880#issuecomment-634666303
@dbtucker @ewencp Do we still need this PR?
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117792#comment-17117792
]
Ismael Juma commented on KAFKA-10007:
-
Do you see segment rolling happening in the b
ijuma commented on pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#issuecomment-634692630
@rajinisivaram We also retain a reference to the `NetworkReceive`, which is
probably a bigger deal, right?
This is
vvcephei commented on pull request #8697:
URL: https://github.com/apache/kafka/pull/8697#issuecomment-634694919
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#issuecomment-634695460
@xiaodongdu please address the conflicts.
This is an automated message from the Apache Git Service.
To respond to t
ijuma commented on pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#issuecomment-634696095
This change is probably OK, but the way we call `close` while iterating over
`completedReceives` seems a bit fragile. It would probably be safer to collect
the items we need to clos
vvcephei commented on pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#issuecomment-634696168
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
ijuma commented on pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#issuecomment-634696784
One more thing, can we improve `KafkaChannel.hashCode/equals` to avoid
unnecessary work? The calls to `Objects.equals` and `Objects.hash` seem
pointless.
-
bbejeck commented on pull request #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-634699859
Java 14 passed,
Java 11 failed with
```Execution failed for task ':connect:mirror:integrationTest'.
21:42:58 > Process 'Gradle Test Executor 48' finished with non-zero ex
vvcephei commented on pull request #8716:
URL: https://github.com/apache/kafka/pull/8716#issuecomment-634702382
The test failures were the result of extra tests that were added on trunk
after this branch. The branch builder does a merge with trunk before running
the tests. I'm rebasing and
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10017:
-
Priority: Blocker (was: Major)
> Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosA
tombentley commented on pull request #8312:
URL: https://github.com/apache/kafka/pull/8312#issuecomment-634705442
@mimaison I've fixed those, if you want to make a 2nd pass. I guess I should
add a test to `KafkaAdminClientTest` too.
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10017:
-
Affects Version/s: 2.6.0
> Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToE
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117819#comment-17117819
]
John Roesler commented on KAFKA-10017:
--
I've just marked this as a blocker for 2.6.
rhauch commented on a change in pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#discussion_r431194915
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java
##
@@ -65,4 +66,12 @@ default void validateReconfiguration(Map conf
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431206147
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/DelayedJoinTest.scala
##
@@ -0,0 +1,73 @@
+/**
+ * Licensed to the Apache Software Foundati
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431208549
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +34,40 @@ import scala.math.{max, min}
*/
private[group] class
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431209368
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +34,40 @@ import scala.math.{max, min}
*/
private[group] class
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-634721500
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
chia7712 commented on a change in pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#discussion_r431210497
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -65,13 +65,24 @@ import scala.compat.java8.OptionConverters._
/*
* Result meta
mumrah commented on pull request #8376:
URL: https://github.com/apache/kafka/pull/8376#issuecomment-634738632
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431247169
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -261,6 +261,42 @@ public void
shouldNo
rhauch commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431212650
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/sink/ErrantRecordReporter.java
##
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-634766420
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
hachikuji merged pull request #7886:
URL: https://github.com/apache/kafka/pull/7886
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
rajinisivaram commented on pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#issuecomment-634769086
@ijuma Based on our discussion, I have added
`Selector#clearCompletedSends()` and `Selector#clearCompletedReceives()` for
SocketServer to clear buffers after they are proces
[
https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9353.
Fix Version/s: 2.6.0
Resolution: Fixed
> Add groupInstanceId to DescribeGroup for be
xiaodongdu commented on a change in pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#discussion_r431267044
##
File path:
clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java
##
@@ -65,4 +66,12 @@ default void validateReconfiguration(Map
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431266629
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3623,22 +3641,26 @@ public RemoveMembersFromConsumerGrou
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117896#comment-17117896
]
Jun Wang commented on KAFKA-4793:
-
{{Look at the pause endpoint, it pause it's tasks.}}
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117896#comment-17117896
]
Jun Wang edited comment on KAFKA-4793 at 5/27/20, 4:23 PM:
---
{{L
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117896#comment-17117896
]
Jun Wang edited comment on KAFKA-4793 at 5/27/20, 4:23 PM:
---
{{L
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9878:
--
Assignee: HaiyuanZhao
> Block AddPartitionsToTxn call until the txn markers are committed
> --
hachikuji commented on a change in pull request #8709:
URL: https://github.com/apache/kafka/pull/8709#discussion_r431288110
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -109,9 +109,19 @@ case class LogReadResult(info: FetchDataInfo,
def withEmpty
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10049:
Priority: Major (was: Blocker)
> KTable-KTable Foreign Key join throwing Serialization Ex
rhauch commented on a change in pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#discussion_r431281159
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java
##
@@ -0,0 +1,297 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10049:
-
Affects Version/s: 2.6.0
> KTable-KTable Foreign Key join throwing Serialization Exception
> --
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10049:
-
Priority: Blocker (was: Major)
> KTable-KTable Foreign Key join throwing Serialization Exceptio
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117922#comment-17117922
]
John Roesler commented on KAFKA-10049:
--
I've marked this as a 2.6 blocker. It's not
ijuma commented on a change in pull request #8709:
URL: https://github.com/apache/kafka/pull/8709#discussion_r431300357
##
File path: core/src/main/scala/kafka/server/ReplicaManager.scala
##
@@ -109,9 +109,19 @@ case class LogReadResult(info: FetchDataInfo,
def withEmptyFetc
ijuma commented on pull request #8709:
URL: https://github.com/apache/kafka/pull/8709#issuecomment-634803238
Argh:
> 09:53:20 [Error]
/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk8-scala2.12/core/src/main/scala/kafka/utils/CoreUtils.scala:326:
value productElementName is not a
ijuma commented on pull request #8709:
URL: https://github.com/apache/kafka/pull/8709#issuecomment-634803985
Looks like `productToString` only works with Scala 2.13. :(
This is an automated message from the Apache Git Service
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431302352
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
##
@@ -51,9 +52,21 @@
if (thro
tombentley commented on a change in pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#discussion_r431305276
##
File path:
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431305795
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
##
@@ -66,6 +79,9 @@
* Returns the se
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-10049:
---
Assignee: John Roesler
> KTable-KTable Foreign Key join throwing Serialization Exce
Sophie Blee-Goldman created KAFKA-10052:
---
Summary: Flaky Test
InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers
Key: KAFKA-10052
URL: https://issues.apache.org/jira/browse/KA
[
https://issues.apache.org/jira/browse/KAFKA-10047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guru Tahasildar reassigned KAFKA-10047:
---
Assignee: Guru Tahasildar
> Unnecessary widening of (int to long) scope in FloatSer
tombentley commented on a change in pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#discussion_r431308724
##
File path:
connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java
##
@@ -0,0 +1,75 @@
+/*
+ * Licensed
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431312462
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3623,22 +3641,26 @@ public RemoveMembersFromConsumerGrou
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117933#comment-17117933
]
Matthias J. Sax commented on KAFKA-10049:
-
Assigned the ticket to [~vvcephei] fo
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431313074
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupOptions.java
##
@@ -37,7 +38,15 @@ public
RemoveMember
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431313236
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -379,6 +380,22 @@ private static MetadataResponse
pr
vvcephei commented on pull request #8716:
URL: https://github.com/apache/kafka/pull/8716#issuecomment-634820186
The only failures were:
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]
org.apache.kafka.streams.integr
mjsax opened a new pull request #8732:
URL: https://github.com/apache/kafka/pull/8732
*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.*
*Summary of testing str
vvcephei commented on pull request #8697:
URL: https://github.com/apache/kafka/pull/8697#issuecomment-634821709
The only failing tests were unrelated:
org.apache.kafka.connect.integration.InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers
org.a
vvcephei commented on pull request #8697:
URL: https://github.com/apache/kafka/pull/8697#issuecomment-634823280
Unbelievable. The java 8 build started running right after I mentioned that
it's not running.
This is an automat
guozhangwang commented on a change in pull request #8716:
URL: https://github.com/apache/kafka/pull/8716#discussion_r431322682
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -1148,6 +1148,9 @@ private void verifyMaxInFlightRequestPerConnec
mjsax commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431322560
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -261,6 +261,42 @@ public void
shouldNotAllo
hachikuji commented on pull request #8709:
URL: https://github.com/apache/kafka/pull/8709#issuecomment-634825301
Bummer. Guess I will revert the commit.
This is an automated message from the Apache Git Service.
To respond to
mjsax commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431323350
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -3623,22 +3641,26 @@ public RemoveMembersFromConsumerGroupResu
guozhangwang merged pull request #8221:
URL: https://github.com/apache/kafka/pull/8221
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
guozhangwang commented on pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-634827126
Thanks for your patience @avalsa ! Merged to trunk.
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9561.
--
Resolution: Fixed
> Update task input partitions when topic metadata changes
>
ableegoldman commented on pull request #8697:
URL: https://github.com/apache/kafka/pull/8697#issuecomment-634827871
> The java 8 build started running right after I mentioned that it's not
running
I hope you'll choose to use these new powers for good
---
mjsax commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431327264
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
##
@@ -51,9 +52,21 @@
if (throwable
mjsax commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431329158
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
##
@@ -66,6 +79,9 @@
* Returns the selecte
mjsax commented on pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#issuecomment-634834525
Java 8:
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[false]
Java 11 and 14 passed. Merging this.
---
1 - 100 of 318 matches
Mail list logo
