showuon commented on code in PR #13135:
URL: https://github.com/apache/kafka/pull/13135#discussion_r1185891570
##
clients/src/main/java/org/apache/kafka/common/utils/ChunkedBytesStream.java:
##
@@ -0,0 +1,357 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
ableegoldman opened a new pull request, #13682:
URL: https://github.com/apache/kafka/pull/13682
Trying to configure the underlying state stores in a join is pretty awkward,
and getting all the parameters right can be particularly frustrating.
At a minimum, we should break up the
[
https://issues.apache.org/jira/browse/KAFKA-14914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720372#comment-17720372
]
li xiangyuan commented on KAFKA-14914:
--
After create this jira ticket we had encountered this
showuon merged PR #13515:
URL: https://github.com/apache/kafka/pull/13515
--
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:
showuon commented on PR #13515:
URL: https://github.com/apache/kafka/pull/13515#issuecomment-1537643776
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
showuon commented on PR #13669:
URL: https://github.com/apache/kafka/pull/13669#issuecomment-1537641986
CI build failed with infra issue. Rebuilding
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13669/3/
--
This is an automated message from the Apache Git Service.
To
mehbey opened a new pull request, #13681:
URL: https://github.com/apache/kafka/pull/13681
This pull requests migrates the ActiveTaskCreator 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.
satishd commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1186813113
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,25 +622,208 @@ public String toString() {
}
}
-long
Erik van Oosten created KAFKA-14972:
---
Summary: Make KafkaConsumer usable in async runtimes
Key: KAFKA-14972
URL: https://issues.apache.org/jira/browse/KAFKA-14972
Project: Kafka
Issue
dajac commented on code in PR #13638:
URL: https://github.com/apache/kafka/pull/13638#discussion_r1186823970
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilder.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache
satishd commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1186813113
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,25 +622,208 @@ public String toString() {
}
}
-long
satishd commented on code in PR #13535:
URL: https://github.com/apache/kafka/pull/13535#discussion_r1186812350
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -600,6 +622,176 @@ public String toString() {
}
}
+public FetchDataInfo
[
https://issues.apache.org/jira/browse/KAFKA-14930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya updated KAFKA-14930:
---
Description:
Add public documentation for the new Kafka Connect offset management REST APIs
from
vamossagar12 commented on PR #13594:
URL: https://github.com/apache/kafka/pull/13594#issuecomment-1537335506
The 2 connect related tests, `testSyncTopicConfigs() –
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest`
and
[
https://issues.apache.org/jira/browse/KAFKA-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao updated KAFKA-14971:
--
Description:
The test testSyncTopicConfigs in
Sagar Rao created KAFKA-14971:
-
Summary: Flaky Test
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest#testSyncTopicConfigs
Key: KAFKA-14971
URL:
16 matches
Mail list logo
