mimaison commented on pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#issuecomment-653745978
Thanks @satishbellapu for the update, it looks good. Can we add a test too?
This is an automated message from the
dongjinleekr commented on pull request #7204:
URL: https://github.com/apache/kafka/pull/7204#issuecomment-653769037
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, plea
[
https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-8794:
---
Labels: needs-kip (was: )
> Provide Javadoc on DescribeLogDirsResult
> -
[
https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-8794:
---
Component/s: clients
> Provide Javadoc on DescribeLogDirsResult
> ---
[
https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-8794:
---
Summary: Deprecate DescribeLogDirsResponse.[LogDirInfo, ReplicaInfo] (was:
Provide Javadoc on Descri
[
https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee updated KAFKA-8794:
---
Description:
As of 2.3.0, {{DescribeLogDirsResult}} returned by
{{AdminClient#describeLogDirs(Collec
kkonstantine commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r449787441
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup()
C0urante commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r449789091
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup() {
kkonstantine commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r449789475
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup()
abbccdda merged pull request #8975:
URL: https://github.com/apache/kafka/pull/8975
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 t
[
https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151399#comment-17151399
]
John Roesler commented on KAFKA-9062:
-
Hi all,
I would like to see KAFKA-10122 fixed
C0urante commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r449797010
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup() {
guozhangwang commented on a change in pull request #8963:
URL: https://github.com/apache/kafka/pull/8963#discussion_r449798211
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -837,6 +866,11 @@ public void init(f
guozhangwang commented on a change in pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#discussion_r449799110
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -270,8 +270,11 @@ public void handleAssignment
guozhangwang commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-653803043
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-653803138
@ableegoldman My understanding is that with this PR the integration test
could still be flaky but should not fail consistently, I saw the last pass
still fail on all cases an
guozhangwang commented on pull request #8962:
URL: https://github.com/apache/kafka/pull/8962#issuecomment-653803935
I've execute the eos upgrade integration test on top of this branch but it
still fails consistently.
This is
[
https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10219:
Labels: needs-kip (was: )
> KStream API support for multiple cluster broker
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10219:
Issue Type: New Feature (was: Bug)
> KStream API support for multiple cluster broker
> --
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151447#comment-17151447
]
ASF GitHub Bot commented on KAFKA-10222:
mjsax commented on pull request #272:
U
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10226:
Component/s: streams
> KStream without SASL information should return error in confluent c
[
https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151448#comment-17151448
]
Guozhang Wang commented on KAFKA-10229:
---
Hello [~rocketraman] thanks for reporting
[
https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mohamed chebbi reassigned KAFKA-10217:
--
Assignee: mohamed chebbi
> Move nodeLevelSensor and storeLevelSensor methods from Str
[
https://issues.apache.org/jira/browse/KAFKA-10229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151456#comment-17151456
]
Raman Gupta commented on KAFKA-10229:
-
[~guozhang] Its the latter case -- the app it
huxihx opened a new pull request #8980:
URL: https://github.com/apache/kafka/pull/8980
https://issues.apache.org/jira/browse/KAFKA-10222
Non-existent methods show up in the doc:
builder.from("my-input-topic").mapValue(value ->
value.length().toString()).to("my-output-topic");
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151457#comment-17151457
]
ASF GitHub Bot commented on KAFKA-10222:
huxihx commented on pull request #272:
huxihx commented on pull request #8980:
URL: https://github.com/apache/kafka/pull/8980#issuecomment-653833070
@mjsax Please review. Thanks.
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151458#comment-17151458
]
ASF GitHub Bot commented on KAFKA-10222:
huxihx closed pull request #272:
URL: h
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17151465#comment-17151465
]
Guozhang Wang commented on KAFKA-10134:
---
[~seanguo] thanks for confirming! As the
29 matches
Mail list logo
