zhaohaidao opened a new pull request #8665:
URL: https://github.com/apache/kafka/pull/8665
Ticket: KAFKA-9984
It indicates a configuration error when consumer subscribes an empty pattern:
```
[Consumer ... ] Subscribed to pattern: ''
```
The
showuon commented on pull request #8623:
URL: https://github.com/apache/kafka/pull/8623#issuecomment-628403219
Hi @kkonstantine , could you please review this small PR? Thanks.
This is an automated message from the Apache
vvcephei commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r424712060
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java
##
@@ -105,6 +109,7 @@ public static String
chia7712 commented on a change in pull request #8663:
URL: https://github.com/apache/kafka/pull/8663#discussion_r424860254
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java
##
@@ -96,6 +101,25 @@ public static void
[
https://issues.apache.org/jira/browse/KAFKA-9981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106865#comment-17106865
]
Andre Price commented on KAFKA-9981:
Not sure if related but I think I'm seeing issues where task
chia7712 commented on a change in pull request #8663:
URL: https://github.com/apache/kafka/pull/8663#discussion_r424859533
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java
##
@@ -108,6 +132,20 @@ public static boolean
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106864#comment-17106864
]
Sophie Blee-Goldman commented on KAFKA-9989:
Yeah that looks like the
chia7712 commented on a change in pull request #8663:
URL: https://github.com/apache/kafka/pull/8663#discussion_r424859533
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SinkConnectorConfig.java
##
@@ -108,6 +132,20 @@ public static boolean
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-9984:
--
Assignee: HaiyuanZhao
> Should fail the subscription when pattern is empty
>
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106857#comment-17106857
]
Boyang Chen commented on KAFKA-9984:
[~guozhang] Thanks!
> Should fail the subscription when pattern
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106853#comment-17106853
]
Boyang Chen commented on KAFKA-9989:
Looks like it is determined by the assignor: (the latest added
[
https://issues.apache.org/jira/browse/KAFKA-9617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106843#comment-17106843
]
Chia-Ping Tsai commented on KAFKA-9617:
---
[https://github.com/apache/kafka/pull/8659]
> Replica
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106832#comment-17106832
]
Sophie Blee-Goldman commented on KAFKA-9987:
Pseudo-code sketch of the algorithm:
{{C_f :=
abbccdda closed pull request #7172:
URL: https://github.com/apache/kafka/pull/7172
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
abbccdda closed pull request #7676:
URL: https://github.com/apache/kafka/pull/7676
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
abbccdda closed pull request #7179:
URL: https://github.com/apache/kafka/pull/7179
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
ableegoldman commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424830762
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java
##
@@ -16,77 +16,58 @@
*/
d8tltanc commented on pull request #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-628340161
Latest dev branch builds here (REMOVE_SYSTEM_4):
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3943/
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424825641
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java
##
@@ -16,77 +16,58 @@
*/
Sophie Blee-Goldman created KAFKA-9991:
--
Summary: Flaky Test
KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled
Key: KAFKA-9991
URL:
[
https://issues.apache.org/jira/browse/KAFKA-9688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe resolved KAFKA-9688.
-
Fix Version/s: 2.5.0
Reviewer: Colin McCabe
Resolution: Fixed
> kafka-topic.sh
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424822166
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java
##
@@ -236,16 +233,17 @@
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424821641
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovementTest.java
##
@@ -35,262 +44,161 @@
import static
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424820836
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -53,75 +67,94 @@ private static
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424819838
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/TaskMovement.java
##
@@ -53,75 +67,94 @@ private static
ableegoldman commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628329507
Nooo
`EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]` still
had one failure on the Java 8 build
But it failed on a different line which
mjsax commented on pull request #6792:
URL: https://github.com/apache/kafka/pull/6792#issuecomment-628323776
@clearpal7 @abbccdda Just cleaning up my old backlog. Do you still want to
get this in? PR would need a rebase.
mjsax commented on pull request #6617:
URL: https://github.com/apache/kafka/pull/6617#issuecomment-628323063
Closing this PR due to inactivity.
This is an automated message from the Apache Git Service.
To respond to the
mjsax closed pull request #6617:
URL: https://github.com/apache/kafka/pull/6617
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 merged pull request #6656:
URL: https://github.com/apache/kafka/pull/6656
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-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9987:
---
Description:
In
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9987:
---
Summary: Improve sticky partition assignor algorithm (was: Add new
cooperative
[
https://issues.apache.org/jira/browse/KAFKA-9850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9850.
Fix Version/s: 2.6.0
Resolution: Fixed
> Move KStream#repartition operator
mjsax merged pull request #8550:
URL: https://github.com/apache/kafka/pull/8550
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 #8550:
URL: https://github.com/apache/kafka/pull/8550#issuecomment-628317830
Thanks for the PR @zhaohaidao! Merged to `trunk`.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9465.
Resolution: Not A Problem
This was fixed implicitly via some code refactoring.
> Enclose
mjsax closed pull request #8001:
URL: https://github.com/apache/kafka/pull/8001
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 #8001:
URL: https://github.com/apache/kafka/pull/8001#issuecomment-628316756
Thanks @guozhangwang. I resolve the Jira ticket. Closing this PR.
This is an automated message from the Apache Git
mjsax commented on a change in pull request #8049:
URL: https://github.com/apache/kafka/pull/8049#discussion_r424805332
##
File path:
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/Serdes.scala
##
@@ -30,12 +32,15 @@ object Serdes {
implicit def
mjsax commented on pull request #8637:
URL: https://github.com/apache/kafka/pull/8637#issuecomment-628315503
@bbejeck Wondering if there are any backward incompatibility concerns? Can
you explain why this change is safe? For #8504 there would be an exception
before and thus it was broken
mjsax commented on pull request #8558:
URL: https://github.com/apache/kafka/pull/8558#issuecomment-628314584
@lkokhreidze Did PR shows a conflict. Can you rebase it?
Btw: did you see the follow up question on the mailing list?
soondenana edited a comment on pull request #8068:
URL: https://github.com/apache/kafka/pull/8068#issuecomment-628308978
Closing PR as this doesn't fix issue.
This is an automated message from the Apache Git Service.
To
soondenana commented on pull request #8068:
URL: https://github.com/apache/kafka/pull/8068#issuecomment-628308978
Issue is now fixed by release team by adding JVM flags for this. This PR is
no longer needed. Closing.
This
soondenana closed pull request #8068:
URL: https://github.com/apache/kafka/pull/8068
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-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106744#comment-17106744
]
Sophie Blee-Goldman commented on KAFKA-9989:
Yeah it would be good to dive into why this is
guozhangwang commented on a change in pull request #8661:
URL: https://github.com/apache/kafka/pull/8661#discussion_r424796625
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -248,17 +243,6 @@ void
rgroothuijsen opened a new pull request #8664:
URL: https://github.com/apache/kafka/pull/8664
There is some confusion over the compression rate metrics, as the meaning of
the value isn't clearly stated in the metric description. In this case, it was
assumed that a higher compression rate
[
https://issues.apache.org/jira/browse/KAFKA-9716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rens Groothuijsen reassigned KAFKA-9716:
Assignee: Rens Groothuijsen
> Values of compression-rate and compression-rate-avg
ijuma commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-628301206
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-9554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-9554:
-
Assignee: Satish Duggana
> Define the SPI for Tiered Storage framework
>
Satish Duggana created KAFKA-9990:
-
Summary: Supporting transactions in tiered storage
Key: KAFKA-9990
URL: https://issues.apache.org/jira/browse/KAFKA-9990
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106731#comment-17106731
]
Matthias J. Sax commented on KAFKA-9989:
Seems like an issue in rebalancing itself? Shouldn't we
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9989:
---
Component/s: system tests
streams
>
mjsax commented on a change in pull request #6824:
URL: https://github.com/apache/kafka/pull/6824#discussion_r424758763
##
File path: docs/streams/developer-guide/processor-api.html
##
@@ -396,33 +396,52 @@ Connecting
Processors and State Stores// and the WordCountProcessor
lbradstreet commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-628293868
@ijuma the updated PR should compile OK. I removed the change to make
SystemTime package private as it seems to be used in other tooling now.
ableegoldman commented on a change in pull request #8661:
URL: https://github.com/apache/kafka/pull/8661#discussion_r424771783
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -248,17 +243,6 @@ void
Boyang Chen created KAFKA-9989:
--
Summary: StreamsUpgradeTest.test_metadata_upgrade could not
guarantee all processor gets assigned task
Key: KAFKA-9989
URL: https://issues.apache.org/jira/browse/KAFKA-9989
cmccabe merged pull request #8556:
URL: https://github.com/apache/kafka/pull/8556
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
guozhangwang commented on a change in pull request #8661:
URL: https://github.com/apache/kafka/pull/8661#discussion_r424761219
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java
##
@@ -248,17 +243,6 @@ void
mjsax commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628272802
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 #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628272606
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424758127
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/TaskAssignorConvergenceTest.java
##
@@ -236,16 +233,17 @@
[
https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106699#comment-17106699
]
Guozhang Wang commented on KAFKA-9659:
--
Hi [~lkokhreidze] Could you try out the latest trunk for
mjsax commented on pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628265887
Retest 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-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-9966.
Fix Version/s: 2.6.0
Resolution: Fixed
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106689#comment-17106689
]
Matthias J. Sax commented on KAFKA-9966:
Also related:
[
https://issues.apache.org/jira/browse/KAFKA-9966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9966:
--
Assignee: Sophie Blee-Goldman (was: Matthias J. Sax)
> Flaky Test
ableegoldman commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r424751772
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -1862,6 +1866,35 @@ public
mjsax merged pull request #8648:
URL: https://github.com/apache/kafka/pull/8648
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 #8662:
URL: https://github.com/apache/kafka/pull/8662#issuecomment-628263949
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #8662:
URL: https://github.com/apache/kafka/pull/8662#discussion_r424750958
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignorTest.java
##
@@ -1862,6 +1866,35 @@ public void
ableegoldman commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424729806
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ConstrainedPrioritySet.java
##
@@ -16,77 +16,58 @@
*/
junrao commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-628258485
@andrewchoi5 : Thanks for finding this issue. We fixed
https://issues.apache.org/jira/browse/KAFKA-9932 recently. So, the
`fetchLogConfig` from ZK method is called rarely during
ijuma commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-628251072
@lbradstreet Compile errors:
> 12:38:04
[
https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya updated KAFKA-9988:
-
Affects Version/s: 2.5.1
2.4.2
2.3.2
vvcephei commented on pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#issuecomment-628236334
It looks like the test failures were unrelated (because they were all
different), some known flaky:
java
[
https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya updated KAFKA-9988:
-
Description:
If the OffsetStorageReader is closed while the task is trying to shutdown,
[
https://issues.apache.org/jira/browse/KAFKA-9988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya updated KAFKA-9988:
-
Summary: Connect incorrectly reports task has failed when task takes too
long to
Sanjana Kaundinya created KAFKA-9988:
Summary: Log incorrectly reports task has failed when task takes
too long to shutdown
Key: KAFKA-9988
URL: https://issues.apache.org/jira/browse/KAFKA-9988
vvcephei commented on a change in pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#discussion_r424718290
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentTestUtils.java
##
@@ -75,4 +94,303 @@
static
apovzner commented on pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#issuecomment-628234920
@dajac Thanks for your very thorough review. I addressed all your comments.
This is an automated message from
apovzner commented on a change in pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#discussion_r424707495
##
File path: core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
##
@@ -0,0 +1,307 @@
+/**
+ * Licensed to the Apache Software Foundation
apovzner commented on a change in pull request #8650:
URL: https://github.com/apache/kafka/pull/8650#discussion_r424706138
##
File path: core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
##
@@ -0,0 +1,307 @@
+/**
+ * Licensed to the Apache Software Foundation
hachikuji commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-628204174
@andrewchoi5 Just want to make sure I understand the problem. The scenario
is that we lose the zk session while handling a LeaderAndIsr request. Current
LeaderAndIsr handling
ijuma commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-628200880
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
lbradstreet commented on pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-628192600
@ijuma can this be merged?
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106558#comment-17106558
]
Matthias J. Sax commented on KAFKA-3184:
I am personally not sure how useful "local
[
https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9897.
--
Resolution: Fixed
> Flaky Test
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106549#comment-17106549
]
Guozhang Wang commented on KAFKA-9984:
--
Sounds good to me :)
> Should fail the subscription when
[
https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106548#comment-17106548
]
Matthias J. Sax commented on KAFKA-9897:
Sure. We can always reopen again if necessary. What what
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-9984:
---
Component/s: (was: streams)
> Should fail the subscription when pattern is empty
>
[
https://issues.apache.org/jira/browse/KAFKA-9982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105942#comment-17105942
]
Chris Egerton edited comment on KAFKA-9982 at 5/13/20, 6:10 PM:
The
[
https://issues.apache.org/jira/browse/KAFKA-9659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106528#comment-17106528
]
Levani Kokhreidze commented on KAFKA-9659:
--
Hi [~guozhang]
Just fyi - we've experienced this
[
https://issues.apache.org/jira/browse/KAFKA-9927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106465#comment-17106465
]
Tom Bentley commented on KAFKA-9927:
[~hachikuji] I've implemented this
[
https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-9987:
---
Summary: Add new cooperative assignor optimized for constant-subscription
group
Sophie Blee-Goldman created KAFKA-9987:
--
Summary: Add new cooperative assignor optimized for
constant-subscription. group
Key: KAFKA-9987
URL: https://issues.apache.org/jira/browse/KAFKA-9987
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8989.
Resolution: Won't Fix
> Embedded broker could not be reached in unit test
>
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106430#comment-17106430
]
Boyang Chen commented on KAFKA-8989:
Lost track, will close.
> Embedded broker could not be reached
[
https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9798.
--
Resolution: Not A Problem
> Flaky test:
>
[
https://issues.apache.org/jira/browse/KAFKA-9927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley reassigned KAFKA-9927:
--
Assignee: Tom Bentley
> Add support for varint types to message generator
>
1 - 100 of 107 matches
Mail list logo
