[
https://issues.apache.org/jira/browse/KAFKA-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10147:
---
Fix Version/s: (was: 2.7.0)
2.6.0
> MockAdminClient#describeConfigs(C
[
https://issues.apache.org/jira/browse/KAFKA-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10147:
---
Fix Version/s: 2.7.0
> MockAdminClient#describeConfigs(Collection) is unable to
> handle br
kkonstantine commented on a change in pull request #8839:
URL: https://github.com/apache/kafka/pull/8839#discussion_r439227501
##
File path: docs/connect.html
##
@@ -180,13 +182,80 @@ TransformationsSetSchemaMetadata - modify the schema name or version
TimestampRouter
ijuma commented on pull request #8857:
URL: https://github.com/apache/kafka/pull/8857#issuecomment-643081702
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
kowshik commented on pull request #8857:
URL: https://github.com/apache/kafka/pull/8857#issuecomment-643080803
cc @ijuma @apovzner @junrao @abbccdda for review.
This is an automated message from the Apache Git Service.
To res
kowshik opened a new pull request #8857:
URL: https://github.com/apache/kafka/pull/8857
The call to `ChangeNotificationProcessorThread.queue.take()` could throw an
`InterruptedException`. While the queue is empty and the thread is blocking on
taking an item from the queue, a concurrent ca
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sean Guo updated KAFKA-10134:
-
Description:
We want to utilize the new rebalance protocol to mitigate the stop-the-world
effect during
Anna Povzner created KAFKA-10157:
Summary: Multiple tests failed due to "Failed to process feature
ZK node change event"
Key: KAFKA-10157
URL: https://issues.apache.org/jira/browse/KAFKA-10157
Project
[
https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10155:
---
Assignee: Chia-Ping Tsai
> Flaky Test ReassignPartitionsUnitTest.testModify
[
https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133891#comment-17133891
]
Sophie Blee-Goldman commented on KAFKA-10155:
-
Oh cool, thanks for the heads
[
https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133856#comment-17133856
]
Chia-Ping Tsai commented on KAFKA-10155:
This issue will be resolved by KAFKA-10
mumrah commented on pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#issuecomment-643035118
The test failures seem to be flaky (KAFKA-10155)
This is an automated message from the Apache Git Service.
To respo
chia7712 commented on a change in pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#discussion_r439170177
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
##
@@ -560,10 +529,14 @@ synchronized private Config
getResourceD
chia7712 commented on a change in pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#discussion_r439167614
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
##
@@ -365,51 +366,6 @@ synchronized public DescribeTopicsResult
ableegoldman commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-643022606
Also failed with unrelated (extremely) flaky
`ReassignPartitionsUnitTest.testModifyBrokerThrottles`
and
`SslSelectorTest.testCloseOldestConnection` (tickets created)
Sophie Blee-Goldman created KAFKA-10156:
---
Summary: Flaky Test SslSelectorTest.testCloseOldestConnection
Key: KAFKA-10156
URL: https://issues.apache.org/jira/browse/KAFKA-10156
Project: Kafka
ableegoldman commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-643022251
Java 11 and 8 failed with (extremely) flaky
`ReassignPartitionsUnitTest.testModifyBrokerThrottles` --
https://issues.apache.org/jira/browse/KAFKA-10155
Java 14 failed
[
https://issues.apache.org/jira/browse/KAFKA-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133836#comment-17133836
]
Chia-Ping Tsai commented on KAFKA-10147:
give blocked as it breaks test
(Reassi
Sophie Blee-Goldman created KAFKA-10155:
---
Summary: Flaky Test
ReassignPartitionsUnitTest.testModifyBrokerThrottles
Key: KAFKA-10155
URL: https://issues.apache.org/jira/browse/KAFKA-10155
Project
[
https://issues.apache.org/jira/browse/KAFKA-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10147:
---
Priority: Blocker (was: Major)
> MockAdminClient#describeConfigs(Collection) is unable to
Dipti Gupta created KAFKA-10154:
---
Summary: Issue in updating metadata if not exists during sending
message to different topics
Key: KAFKA-10154
URL: https://issues.apache.org/jira/browse/KAFKA-10154
Pro
andrewchoi5 commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-643017385
> > In the catch case for ZooKeeperClientException, I have populated the
responseMap with the topic partition and the `Errors.NETWORK_EXCEPTION`. If you
suggest any other Erro
jjkoshy commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-643015314
> In the catch case for ZooKeeperClientException, I have populated the
responseMap with the topic partition and the `Errors.NETWORK_EXCEPTION`. If you
suggest any other Error
skaundinya15 commented on pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#issuecomment-643012766
Thanks for the reviews @hachikuji. I updated the PR per your suggestions and
left some follow up comments for clarification. Whenever you're ready, the PR
is ready for anothe
skaundinya15 commented on a change in pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#discussion_r439156564
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1784,8 +1785,24 @@ class Log(@volatile private var _dir: File,
private def deleteRetent
andrewchoi5 commented on pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#issuecomment-643010366
Hi @junrao. Thank you for your review -- I have further synced up with
@jjkoshy on this PR.
The partition's new leader epoch update is actually happening after the
poin
skaundinya15 commented on a change in pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#discussion_r439155424
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1702,11 +1702,12 @@ class Log(@volatile private var _dir: File,
* (if
guozhangwang commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-643007770
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-643007836
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
guozhangwang commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-643007754
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on pull request #8856:
URL: https://github.com/apache/kafka/pull/8856#issuecomment-643003389
@guozhangwang @mjsax @vvcephei
This is an automated message from the Apache Git Service.
To respond to the m
ableegoldman opened a new pull request #8856:
URL: https://github.com/apache/kafka/pull/8856
1. KAFKA-10150:
- always transition to SUSPENDED during `suspend`, no matter the current
state
- only call `prepareCommit` before closing if `task.commitNeeded` is true
2. Don't co
apovzner commented on a change in pull request #8768:
URL: https://github.com/apache/kafka/pull/8768#discussion_r439143850
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1256,11 +1272,17 @@ class ConnectionQuotas(config: KafkaConfig, time: Time)
exte
guozhangwang commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642992126
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
mjsax opened a new pull request #8855:
URL: https://github.com/apache/kafka/pull/8855
*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
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Tan updated KAFKA-9800:
-
Description:
Design:
The main idea is to bookkeep the failed attempt. Currently, the retry backoff
has
ableegoldman commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642984741
Unrelated flaky test failed:
`kafka.admin.ReassignPartitionsUnitTest.testModifyBrokerThrottles`
This is an
[
https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-8686.
---
Resolution: Fixed
This test class has been running dependably for some time.
kkonstantine commented on pull request #7224:
URL: https://github.com/apache/kafka/pull/7224#issuecomment-642975105
@rhauch https://github.com/apache/kafka/pull/8805 seems to have fixed the
root cause of these failures. The tests haven't failed since then. They seem
more reliable now, at l
[
https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-8661.
---
Resolution: Fixed
The tests have been fixed and reenabled with
[https://gi
[
https://issues.apache.org/jira/browse/KAFKA-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-8661:
--
Fix Version/s: 2.5.1
2.4.2
2.3.2
> Flaky
[
https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis reassigned KAFKA-8686:
-
Assignee: Konstantine Karantasis
> Flaky test ExampleConnectIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis reassigned KAFKA-8555:
-
Assignee: Konstantine Karantasis
> Flaky test ExampleConnectIntegrationT
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-8391.
---
Resolution: Fixed
The tests have been fixed and reenabled with
[https://gi
[
https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis updated KAFKA-8391:
--
Fix Version/s: 2.5.1
2.4.2
2.3.2
> Flaky
mjsax commented on pull request #8849:
URL: https://github.com/apache/kafka/pull/8849#issuecomment-642968031
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
mjsax commented on pull request #8852:
URL: https://github.com/apache/kafka/pull/8852#issuecomment-642966020
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
abbccdda commented on a change in pull request #8853:
URL: https://github.com/apache/kafka/pull/8853#discussion_r439101876
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
##
@@ -560,10 +529,14 @@ synchronized private Config
getResourceD
guozhangwang commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r439093372
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -210,9 +214,8 @@ public void handleAssignment(
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r439086416
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -210,9 +214,8 @@ public void handleAssignment(
[
https://issues.apache.org/jira/browse/KAFKA-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bob Barrett reassigned KAFKA-10149:
---
Assignee: Bob Barrett
> Do not prevent automatic preferred election when reassignment in pr
[
https://issues.apache.org/jira/browse/KAFKA-10153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aakash Shah updated KAFKA-10153:
Component/s: KafkaConnect
> Documentation for the Errant Record Reporter
> ---
Aakash Shah created KAFKA-10153:
---
Summary: Documentation for the Errant Record Reporter
Key: KAFKA-10153
URL: https://issues.apache.org/jira/browse/KAFKA-10153
Project: Kafka
Issue Type: Task
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r439075789
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
guozhangwang commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r439074869
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
[
https://issues.apache.org/jira/browse/KAFKA-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10152:
---
Assignee: Sophie Blee-Goldman
> Attempt to write checkpoint without first c
vvcephei commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642902146
I've noticed that if you complain, you tend to get results...
This is an automated message from the Apache Git Se
vvcephei commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642902034
Ah, there we go :)
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642901512
Hey @bellemare , Thanks so much for the update! Jenkins has been a bit lazy
recently, so I'll probably be pinging it for a while...
-
vvcephei commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642901027
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 #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642900612
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Sophie Blee-Goldman created KAFKA-10152:
---
Summary: Attempt to write checkpoint without first committing
during recycle
Key: KAFKA-10152
URL: https://issues.apache.org/jira/browse/KAFKA-10152
Pro
[
https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10151:
Summary: Flaky Test
StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueSto
hachikuji commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r439009094
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -978,7 +1000,7 @@ public boolean hasValidPos
Sophie Blee-Goldman created KAFKA-10151:
---
Summary: Flaky Test
StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapiStoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKey
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r439004982
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
hachikuji commented on a change in pull request #8850:
URL: https://github.com/apache/kafka/pull/8850#discussion_r438997622
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1702,11 +1702,12 @@ class Log(@volatile private var _dir: File,
* (if th
tombentley commented on pull request #8312:
URL: https://github.com/apache/kafka/pull/8312#issuecomment-642863307
@mimaison done.
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10027.
-
Fix Version/s: 2.7.0
Assignee: Kowshik Prakasam
Resolution: Fixed
merged the PR to trunk
junrao merged pull request #8680:
URL: https://github.com/apache/kafka/pull/8680
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
junrao commented on pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#issuecomment-642855293
The test failures seem unrelated. Merging this to trunk.
This is an automated message from the Apache Git Service.
Sophie Blee-Goldman created KAFKA-10150:
---
Summary: IllegalStateException when revoking task in CREATED state
Key: KAFKA-10150
URL: https://issues.apache.org/jira/browse/KAFKA-10150
Project: Kafka
Jason Gustafson created KAFKA-10149:
---
Summary: Do not prevent automatic preferred election when
reassignment in progress
Key: KAFKA-10149
URL: https://issues.apache.org/jira/browse/KAFKA-10149
Proje
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r438957621
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r438953766
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
ableegoldman commented on a change in pull request #8833:
URL: https://github.com/apache/kafka/pull/8833#discussion_r438953766
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -504,88 +438,66 @@ public void update(final Set
[
https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis resolved KAFKA-8555.
---
Resolution: Fixed
This test class has been running dependably for some time.
[
https://issues.apache.org/jira/browse/KAFKA-9851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9851:
-
Component/s: KafkaConnect
> Revoking Connect tasks due to connectivity issues should also clear r
bbejeck commented on pull request #6229:
URL: https://github.com/apache/kafka/pull/6229#issuecomment-642777124
Hi @sh-abhi,
>'m having some difficulty doing a rebase successfully after trying some
different approaches based on some references I found online.
This PR looks good
bbejeck commented on pull request #6229:
URL: https://github.com/apache/kafka/pull/6229#issuecomment-642774237
Ok to test.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
junrao commented on pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#issuecomment-642751664
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on
junrao commented on pull request #8680:
URL: https://github.com/apache/kafka/pull/8680#issuecomment-642750609
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-10146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10146:
--
Labels: backport (was: )
> Backport KAFKA-9066 to 2.5 and 2.4 branches
>
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Affects Version/s: (was: 2.7.0)
> Standby state isn't always re-used when transitioning to a
[
https://issues.apache.org/jira/browse/KAFKA-10146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10146:
--
Issue Type: Task (was: Bug)
> Backport KAFKA-9066 to 2.5 and 2.4 branches
> -
[
https://issues.apache.org/jira/browse/KAFKA-10086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10086:
-
Fix Version/s: (was: 2.7.0)
> Standby state isn't always re-used when transitioning to activ
[
https://issues.apache.org/jira/browse/KAFKA-10146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133340#comment-17133340
]
Randall Hauch commented on KAFKA-10146:
---
Added PR: https://github.com/apache/kafka
[
https://issues.apache.org/jira/browse/KAFKA-10146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133343#comment-17133343
]
Randall Hauch commented on KAFKA-10146:
---
Be sure to update KAFKA-9066 fix versions
mumrah commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r438870452
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -978,7 +1000,7 @@ public boolean hasValidPositi
rhauch opened a new pull request #8854:
URL: https://github.com/apache/kafka/pull/8854
Targets the `2.5` branch, and should be backported to the `2.4` branch.
This backports the KAFKA-9066 / #8502 changes to retain metrics for failed
tasks that was already merged to `trunk` and backp
mumrah commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r438870452
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
##
@@ -978,7 +1000,7 @@ public boolean hasValidPositi
[
https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9374.
--
Reviewer: Konstantine Karantasis
Resolution: Fixed
Merged to `trunk` and backported to th
[
https://issues.apache.org/jira/browse/KAFKA-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9374:
-
Fix Version/s: 2.6.0
> Worker can be disabled by blocked connectors
> ---
mumrah commented on a change in pull request #8841:
URL: https://github.com/apache/kafka/pull/8841#discussion_r438867535
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java
##
@@ -675,36 +676,41 @@ private ListOffsetResult
fetchOffsets
[
https://issues.apache.org/jira/browse/KAFKA-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9969.
--
Reviewer: Konstantine Karantasis
Resolution: Fixed
[~kkonstantine] merged to `trunk` and
[
https://issues.apache.org/jira/browse/KAFKA-9969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9969:
-
Fix Version/s: 2.5.1
2.4.2
2.6.0
2.3.2
>
[
https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10148:
--
Description:
System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a
[
https://issues.apache.org/jira/browse/KAFKA-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-10148:
--
Description:
System test {{StreamsEosTest.test_failure_and_recovery}} for eos-beta exposes a
bellemare commented on pull request #8764:
URL: https://github.com/apache/kafka/pull/8764#issuecomment-642720296
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
1 - 100 of 134 matches
Mail list logo
