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
[
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
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
Sagar Rao created KAFKA-14971:
-
Summary: Flaky Test
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest#testSyncTopicConfigs
Key: KAFKA-14971
URL:
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
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
[
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
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
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
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.
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
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
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 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:
[
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
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
16 matches
Mail list logo