wcarlson5 commented on code in PR #13855:
URL: https://github.com/apache/kafka/pull/13855#discussion_r1234687152
##
streams/src/test/java/org/apache/kafka/streams/integration/StreamTableJoinWithGraceIntegrationTest.java:
##
@@ -0,0 +1,144 @@
+/*
+ * Licensed to the Apache
wcarlson5 opened a new pull request, #13878:
URL: https://github.com/apache/kafka/pull/13878
Upgrade RocksDBTimeOrderedKeyValueBufferTest to use Junit5
*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected
wcarlson5 commented on PR #13855:
URL: https://github.com/apache/kafka/pull/13855#issuecomment-1598038798
@cadonna I got around to updating the tests as well like you asked
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
hudeqi opened a new pull request, #13877:
URL: https://github.com/apache/kafka/pull/13877
A minor fix hint.
--
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 specific comment.
To unsubscribe,
wcarlson5 commented on code in PR #13855:
URL: https://github.com/apache/kafka/pull/13855#discussion_r1232839068
##
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinWithGraceTest.java:
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-15107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-15107:
---
Labels: tiered-storage (was: )
> Additional custom metadata for remote log segment
>
cmccabe closed pull request #13826: KAFKA-15060: fix the ApiVersionManager
interface
URL: https://github.com/apache/kafka/pull/13826
--
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 specific
cmccabe commented on PR #13826:
URL: https://github.com/apache/kafka/pull/13826#issuecomment-1597881564
merged
--
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 specific comment.
To
abbccdda closed pull request #6895: KAFKA-8489: Remove group immediately upon
Dead state
URL: https://github.com/apache/kafka/pull/6895
--
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 specific
abbccdda closed pull request #8110: DEBUG: Handle OutOfSequence error on Stream
Thread
URL: https://github.com/apache/kafka/pull/8110
--
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 specific
lucasbru opened a new pull request, #13876:
URL: https://github.com/apache/kafka/pull/13876
- In one case, throw `CorrelationIdMismatchException` instead of
`RuntimeException`.
- Use `IllegalStateException` for all states that should be impossible to
reach
- `FENCED_INSTANCE_ID`,
divijvaidya commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234237168
##
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala:
##
@@ -28,13 +28,12 @@ import org.apache.kafka.server.quota.ClientQuotaCallback
import
cadonna commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1597409327
Once the build are acceptable, I am going to merge this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
cadonna commented on code in PR #12739:
URL: https://github.com/apache/kafka/pull/12739#discussion_r1234220438
##
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingPersistentWindowStoreTest.java:
##
@@ -144,45 +148,35 @@ public void closeStore() {
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
jlprat commented on PR #13840:
URL: https://github.com/apache/kafka/pull/13840#issuecomment-1597378453
> So, I think the change I made makes things clearer in the end.
I agree. Thanks @ijuma
--
This is an automated message from the Apache Git Service.
To respond to the message,
ijuma commented on PR #13582:
URL: https://github.com/apache/kafka/pull/13582#issuecomment-1597377059
Looks like there is a spotbugs issue, I'll investigate that.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
ijuma commented on PR #13582:
URL: https://github.com/apache/kafka/pull/13582#issuecomment-1597375537
@divijvaidya if you're comfortable, I think this is ready to be merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ijuma commented on PR #13840:
URL: https://github.com/apache/kafka/pull/13840#issuecomment-1597374541
Thanks for the reviews. A couple of responses.
> I don't think we are hitting those, but I just wanted to make sure we are
aware of these before merging.
Yes, I saw that note
ijuma commented on code in PR #13840:
URL: https://github.com/apache/kafka/pull/13840#discussion_r1234197390
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2499,15 +2499,16 @@ class ReplicaManagerTest {
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234194014
##
core/src/main/scala/kafka/server/ClientRequestQuotaManager.scala:
##
@@ -28,13 +28,12 @@ import org.apache.kafka.server.quota.ClientQuotaCallback
import
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Summary: task.timeout.ms does not work when TimeoutException is thrown by
streams
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Summary: task.timeout.ms does not work when TimeoutException is thrown by
stream
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms does not work when TimeoutException is
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Summary: Task.timeout.ms does not work when TimeoutException is thrown by
stream
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms doesn't work for the stream producer
--
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms doesn't work for the stream producer
--
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms doesn't work for the stream producer
--
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms doesn't work for the stream producer
--
[
https://issues.apache.org/jira/browse/KAFKA-15108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomonari Yamashita updated KAFKA-15108:
---
Description:
[Problem]
- task.timeout.ms doesn't work for the stream producer
--
Tomonari Yamashita created KAFKA-15108:
--
Summary: task.timeout.ms doesn't work for the stream producer
Key: KAFKA-15108
URL: https://issues.apache.org/jira/browse/KAFKA-15108
Project: Kafka
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234178162
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -574,6 +574,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
def
mimaison merged PR #13875:
URL: https://github.com/apache/kafka/pull/13875
--
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 specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/KAFKA-15107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko updated KAFKA-15107:
---
Description:
Based on the [KIP-917: Additional custom metadata for remote log
divijvaidya commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234166769
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -574,6 +574,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
def
machi1990 commented on PR #13700:
URL: https://github.com/apache/kafka/pull/13700#issuecomment-1597319479
> Thank you for the PR. It's worth noting that the ClientQuotaManagers are
shutdown on broker shutdown and hence, it's not a big deal if we are leaking
metrics right now. Nevertheless,
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234159704
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -418,6 +418,17 @@ class ClientQuotaManagerTest extends
BaseClientQuotaManagerTest {
divijvaidya commented on PR #13850:
URL: https://github.com/apache/kafka/pull/13850#issuecomment-1597273967
Rebasing from trunk to fix flaky CI test failures.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mimaison commented on PR #13875:
URL: https://github.com/apache/kafka/pull/13875#issuecomment-1597266192
Matching PR for kafka-site: https://github.com/apache/kafka/pull/13875
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234120547
##
core/src/main/scala/kafka/server/ClientQuotaManager.scala:
##
@@ -572,6 +572,7 @@ class ClientQuotaManager(private val config:
ClientQuotaManagerConfig,
}
mimaison opened a new pull request, #13875:
URL: https://github.com/apache/kafka/pull/13875
This unclosed `code` tag messes with the formatting:
https://github.com/apache/kafka/assets/903615/c7b4f391-b527-4674-acd0-3d92595fa5b1;>
### Committer Checklist (excluded from commit
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234120168
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -418,6 +418,17 @@ class ClientQuotaManagerTest extends
BaseClientQuotaManagerTest {
machi1990 commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1234119510
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -418,6 +418,17 @@ class ClientQuotaManagerTest extends
BaseClientQuotaManagerTest {
machi1990 commented on PR #13665:
URL: https://github.com/apache/kafka/pull/13665#issuecomment-1597260242
@showuon I was looking onto this and after several local runs, I managed to
eliminate some flasky test and came up with the list of failures that are only
caused by this change. The
[
https://issues.apache.org/jira/browse/KAFKA-15085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya resolved KAFKA-15085.
--
Reviewer: Divij Vaidya
Resolution: Fixed
> Make Timer.java implement AutoCloseable
>
[
https://issues.apache.org/jira/browse/KAFKA-15085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya reassigned KAFKA-15085:
Assignee: Joobi S B
> Make Timer.java implement AutoCloseable
>
[
https://issues.apache.org/jira/browse/KAFKA-15085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15085:
-
Fix Version/s: 3.6.0
> Make Timer.java implement AutoCloseable
>
divijvaidya merged PR #13872:
URL: https://github.com/apache/kafka/pull/13872
--
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 specific comment.
To unsubscribe, e-mail:
viktorsomogyi commented on code in PR #12290:
URL: https://github.com/apache/kafka/pull/12290#discussion_r1234081443
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java:
##
@@ -350,13 +353,16 @@ private void
showuon commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1233980545
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -117,51 +128,60 @@ class RemoteIndexCacheTest {
@Test
def
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233967737
##
core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala:
##
@@ -37,7 +39,8 @@ class TransactionDataAndCallbacks(val transactionData:
satishd commented on PR #13850:
URL: https://github.com/apache/kafka/pull/13850#issuecomment-1597070428
>I understand what you are saying. I did consider that approach. So that we
are on the same page, the approach looks like:
...
Caffeine on the other hand doesn't have any of the
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233955360
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -366,16 +367,16 @@ class BrokerToControllerRequestThread(
val
divijvaidya commented on code in PR #13700:
URL: https://github.com/apache/kafka/pull/13700#discussion_r1233939989
##
core/src/test/scala/unit/kafka/server/ClientQuotaManagerTest.scala:
##
@@ -418,6 +418,17 @@ class ClientQuotaManagerTest extends
BaseClientQuotaManagerTest {
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233946298
##
server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233945004
##
server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
satishd commented on PR #13561:
URL: https://github.com/apache/kafka/pull/13561#issuecomment-1597034800
> @satishd , any update for this PR? If you don't have time on it, just let
me know. :)
addressing the review comments in progress, needs minor refactoring which is
going on. Will
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233937877
##
server-common/src/test/java/org/apache/kafka/server/util/InterBrokerSendThreadTest.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache Software
yashmayya commented on code in PR #13801:
URL: https://github.com/apache/kafka/pull/13801#discussion_r1233861544
##
connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java:
##
@@ -140,6 +142,9 @@ public static ConnectorOffsetBackingStore
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233934433
##
server-common/src/main/java/org/apache/kafka/server/util/RequestAndCompletionHandler.java:
##
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233928519
##
server-common/src/main/java/org/apache/kafka/server/util/RequestAndCompletionHandler.java:
##
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software
Ivan Yurchenko created KAFKA-15107:
--
Summary: Additional custom metadata for remote log segment
Key: KAFKA-15107
URL: https://issues.apache.org/jira/browse/KAFKA-15107
Project: Kafka
Issue
divijvaidya merged PR #13341:
URL: https://github.com/apache/kafka/pull/13341
--
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 specific comment.
To unsubscribe, e-mail:
viktorsomogyi commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1596994184
> In addition, if we add integration tests, put them in this PR, or need to
open another PR?
Let's add them to this PR.
--
This is an automated message from the Apache Git
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233905670
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Licensed to the Apache Software
zigarn commented on PR #12976:
URL: https://github.com/apache/kafka/pull/12976#issuecomment-1596990442
Thanks @divijvaidya!
--
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 specific comment.
divijvaidya merged PR #12976:
URL: https://github.com/apache/kafka/pull/12976
--
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 specific comment.
To unsubscribe, e-mail:
vamossagar12 commented on PR #13158:
URL: https://github.com/apache/kafka/pull/13158#issuecomment-1596987677
> > I would keep the work that has been done
>
> I agree. This work is already in use in another PR.
I see. In that case, I need to fix the build issue and ask folks for
divijvaidya commented on PR #12976:
URL: https://github.com/apache/kafka/pull/12976#issuecomment-1596983653
Unrelated failures:
```
[Build / JDK 17 and Scala 2.13 /
clolov commented on code in PR #13421:
URL: https://github.com/apache/kafka/pull/13421#discussion_r1233898970
##
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala:
##
@@ -196,6 +201,110 @@ class ReplicaAlterLogDirsThreadTest {
assertEquals(0,
[
https://issues.apache.org/jira/browse/KAFKA-15052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15052:
-
Labels: flaky-test (was: )
> Fix flaky test QuorumControllerTest.testBalancePartitionLeaders()
clolov commented on code in PR #13421:
URL: https://github.com/apache/kafka/pull/13421#discussion_r1233892585
##
core/src/main/scala/kafka/server/AbstractFetcherThread.scala:
##
@@ -706,6 +706,8 @@ abstract class AbstractFetcherThread(name: String,
*- the request
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233888595
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-15096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15096:
-
Fix Version/s: 3.4.2
3.3.3
3.6.0
> CVE 2023-34455 -
[
https://issues.apache.org/jira/browse/KAFKA-15096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734119#comment-17734119
]
Josep Prat commented on KAFKA-15096:
I cherry-picked this to 3.3, 3.4 and 3.5
> CVE 2023-34455 -
[
https://issues.apache.org/jira/browse/KAFKA-15096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-15096:
---
Fix Version/s: 3.5.1
> CVE 2023-34455 - Vulnerability identified with Apache kafka
>
clolov commented on code in PR #13847:
URL: https://github.com/apache/kafka/pull/13847#discussion_r1233880437
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -881,6 +881,7 @@ class ReplicaManager(val config: KafkaConfig,
if
[
https://issues.apache.org/jira/browse/KAFKA-15096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-15096:
---
Affects Version/s: 3.4.1
3.5.0
3.3.2
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233883878
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Licensed to the Apache Software
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233883671
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Licensed to the Apache Software
Vaibhav-Nazare commented on PR #13817:
URL: https://github.com/apache/kafka/pull/13817#issuecomment-1596959362
HI @divijvaidya Thanks for the information , I have created a discussion
thread for the KIP as per given process
[
https://issues.apache.org/jira/browse/KAFKA-15099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17734117#comment-17734117
]
Divij Vaidya commented on KAFKA-15099:
--
Another instance for kraft only failure:
[
https://issues.apache.org/jira/browse/KAFKA-15099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15099:
-
Component/s: unit tests
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-15099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-15099:
-
Labels: flaky-test (was: )
> Flaky Test
>
[
https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
li xiangyuan updated KAFKA-15106:
-
Description:
this could reproduce in ut easy,
just int
dimitarndimitrov commented on code in PR #13856:
URL: https://github.com/apache/kafka/pull/13856#discussion_r1233880362
##
server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java:
##
@@ -0,0 +1,253 @@
+/*
+ * Licensed to the Apache Software
jlprat commented on PR #13865:
URL: https://github.com/apache/kafka/pull/13865#issuecomment-1596954634
Cherry-picked to 3.3, 3.4 and 3.5
--
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
clolov opened a new pull request, #13873:
URL: https://github.com/apache/kafka/pull/13873
This pull requests migrates the Consumer mock in TaskManagerTest from
EasyMock to Mockito.
The change is restricted to a single mock to minimize the scope and make it
easier for review.
The
[
https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
li xiangyuan updated KAFKA-15106:
-
Due Date: 19/Jun/23 (was: 14/Apr/23)
> AbstractStickyAssignor may stuck in 3.5
>
li xiangyuan created KAFKA-15106:
Summary: AbstractStickyAssignor may stuck in 3.5
Key: KAFKA-15106
URL: https://issues.apache.org/jira/browse/KAFKA-15106
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
li xiangyuan updated KAFKA-15106:
-
Description:
this could reproduce in ut easy,
just int
[
https://issues.apache.org/jira/browse/KAFKA-15106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
li xiangyuan updated KAFKA-15106:
-
Description:
this could reproduce in ut easily,
just int
viktorsomogyi commented on PR #13819:
URL: https://github.com/apache/kafka/pull/13819#issuecomment-1596930181
no problem
--
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 specific comment.
divijvaidya commented on code in PR #13850:
URL: https://github.com/apache/kafka/pull/13850#discussion_r1233856967
##
core/src/main/scala/kafka/log/remote/RemoteIndexCache.scala:
##
@@ -37,88 +40,125 @@ object RemoteIndexCache {
val TmpFileSuffix = ".tmp"
}
-class
showuon commented on PR #13561:
URL: https://github.com/apache/kafka/pull/13561#issuecomment-1596907836
@satishd , any update for this PR? If you don't have time on it, just let me
know. :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
1 - 100 of 159 matches
Mail list logo
