rhauch commented on a change in pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#discussion_r431328464
##
File path:
connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTest.java
##
@@ -0,0 +1,65 @@
+/*
+ *
mjsax commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-634846209
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 #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-634846336
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-634846388
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on a change in pull request #8716:
URL: https://github.com/apache/kafka/pull/8716#discussion_r431342011
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the
feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r431341731
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -261,6 +261,42 @@ public void
mjsax commented on pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#issuecomment-634840600
Thanks for the KIP and PR @pgwhalen!
This is an automated message from the Apache Git Service.
To respond to the
mjsax merged pull request #6824:
URL: https://github.com/apache/kafka/pull/6824
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
ableegoldman commented on a change in pull request #8716:
URL: https://github.com/apache/kafka/pull/8716#discussion_r431326390
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -874,7 +874,7 @@
public static final String TIME =
rhauch commented on pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#issuecomment-634836169
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
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.
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
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
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
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
[
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
>
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
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
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_r431322560
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractResetIntegrationTest.java
##
@@ -261,6 +261,42 @@ public void
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
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
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
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
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]
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117933#comment-17117933
]
Matthias J. Sax commented on KAFKA-10049:
-
Assigned the ticket to [~vvcephei] for now. Not sure
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
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 @@
+/*
+ *
Sophie Blee-Goldman created KAFKA-10052:
---
Summary: Flaky Test
InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers
Key: KAFKA-10052
URL:
[
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
[
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
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
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_r431302352
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/RemoveMembersFromConsumerGroupResult.java
##
@@ -51,9 +52,21 @@
if
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
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 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
[
https://issues.apache.org/jira/browse/KAFKA-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117922#comment-17117922
]
John Roesler commented on KAFKA-10049:
--
I've marked this as a 2.6 blocker. It's not immediately
[
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
[
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
>
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
[
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
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117896#comment-17117896
]
Jun Wang edited comment on KAFKA-4793 at 5/27/20, 4:23 PM:
---
{{Look at the pause
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117896#comment-17117896
]
Jun Wang edited comment on KAFKA-4793 at 5/27/20, 4:23 PM:
---
{{Look at the pause
[
https://issues.apache.org/jira/browse/KAFKA-4793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117896#comment-17117896
]
Jun Wang commented on KAFKA-4793:
-
{{Look at the pause endpoint, it pause it's tasks.}}
{{}}
{noformat}
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
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
[
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
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
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
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
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
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
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
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
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
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
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_r431206147
##
File path:
core/src/test/scala/unit/kafka/coordinator/group/DelayedJoinTest.scala
##
@@ -0,0 +1,73 @@
+/**
+ * Licensed to the Apache Software
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
[
https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117819#comment-17117819
]
John Roesler commented on KAFKA-10017:
--
I've just marked this as a blocker for 2.6.0. It's been
[
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
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
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
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
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.
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117792#comment-17117792
]
Ismael Juma commented on KAFKA-10007:
-
Do you see segment rolling happening in the broker shortly
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
[
https://issues.apache.org/jira/browse/KAFKA-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117760#comment-17117760
]
Raman Gupta commented on KAFKA-10007:
-
It certainly could be. I'm not certain KAFKA-9543 listed too
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).
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).
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117750#comment-17117750
]
Ella Kurginyan commented on KAFKA-7500:
---
Hi [~ryannedolan]. Now I can't find class
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.
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,
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 #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
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
[
https://issues.apache.org/jira/browse/KAFKA-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117673#comment-17117673
]
Nikolay Izhikov commented on KAFKA-10050:
-
Results with the patch:
{noformat}
[
https://issues.apache.org/jira/browse/KAFKA-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117661#comment-17117661
]
Stefan Zwanenburg commented on KAFKA-10051:
---
Ah. The release notes mentioned a deprecation,
[
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
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-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
>
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
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117609#comment-17117609
]
Marouane RAJI edited comment on KAFKA-4090 at 5/27/20, 10:11 AM:
-
Hey,
[
https://issues.apache.org/jira/browse/KAFKA-4090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117609#comment-17117609
]
Marouane RAJI commented on KAFKA-4090:
--
Hey,
We ran into this issue with Samza jobs using a Kafka
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
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_r431001869
##
File path: core/src/main/scala/kafka/coordinator/group/DelayedJoin.scala
##
@@ -33,11 +33,15 @@ import scala.math.{max, min}
*/
private[group] class
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
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)
201 - 300 of 313 matches
Mail list logo