dongjinleekr commented on pull request #9414:
URL: https://github.com/apache/kafka/pull/9414#issuecomment-733525231
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-10717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238576#comment-17238576
]
Stefan Bejan commented on KAFKA-10717:
--
We just tried the same scenariio using Kafk
[
https://issues.apache.org/jira/browse/KAFKA-10765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lqjacklee reassigned KAFKA-10765:
-
Assignee: lqjacklee
> Task :stream:test-utils:test FAILED
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238553#comment-17238553
]
lqjacklee commented on KAFKA-10765:
---
[~xiaopenglei]
{code:java}
2119 ± : ./gradlew
lmr3796 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r530139420
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -107,6 +108,11 @@ class KafkaApisTest {
private val time = new MockTime
PengLei created KAFKA-10765:
---
Summary: Task :stream:test-utils:test FAILED
Key: KAFKA-10765
URL: https://issues.apache.org/jira/browse/KAFKA-10765
Project: Kafka
Issue Type: Sub-task
Comp
showuon commented on pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#issuecomment-733498016
@abbccdda @guozhangwang , could you please help review this PR? Thanks.
This is an automated message from the Ap
showuon opened a new pull request #9650:
URL: https://github.com/apache/kafka/pull/9650
Before:
After:
> Add topic ID support to DeleteTopics,ListOffset
[
https://issues.apache.org/jira/browse/KAFKA-10580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10580:
--
Assignee: (was: Justine Olshan)
> Add topic ID support to Fetch request
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10548:
--
Assignee: (was: Justine Olshan)
> Implement deletion logic for LeaderAndIsrReques
[
https://issues.apache.org/jira/browse/KAFKA-10764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-10764:
--
Assignee: Justine Olshan
> Add support for returning topic IDs on create, supplying t
Justine Olshan created KAFKA-10764:
--
Summary: Add support for returning topic IDs on create, supplying
topic IDs for delete
Key: KAFKA-10764
URL: https://issues.apache.org/jira/browse/KAFKA-10764
Pro
[
https://issues.apache.org/jira/browse/KAFKA-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10550:
---
Description:
Change describe topics AdminClient method to expose and support topic IDs
[
https://issues.apache.org/jira/browse/KAFKA-10550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238281#comment-17238281
]
Justine Olshan commented on KAFKA-10550:
Sounds good. I'll make a separate ticke
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r529716169
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Ap
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r529713764
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -894,19 +885,88 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r529709595
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Ap
wcarlson5 commented on pull request #9629:
URL: https://github.com/apache/kafka/pull/9629#issuecomment-733088175
These changes LGTM. WDYT @ableegoldman? thanks for the PR!
This is an automated message from the Apache Git Serv
[
https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238230#comment-17238230
]
Gary Russell edited comment on KAFKA-10384 at 11/24/20, 4:00 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238230#comment-17238230
]
Gary Russell commented on KAFKA-10384:
--
Is there any change the provided scope can
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r529623275
##
File path: clients/src/main/resources/common/message/LeaderChangeMessage.json
##
@@ -22,7 +22,9 @@
{"name": "LeaderId", "type": "int32", "versi
[
https://issues.apache.org/jira/browse/KAFKA-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17238187#comment-17238187
]
rameshkrishnan muthusamy commented on KAFKA-10315:
--
[~showuon] [~mjsax]
jsancio commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r529572270
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -370,14 +370,23 @@ private void onBecomeLeader(long currentTimeMs) {
ijuma commented on pull request #9643:
URL: https://github.com/apache/kafka/pull/9643#issuecomment-733008676
I reverted the Scala 2.12.13 change, looks like this hasn't been published
to Maven yet.
This is an automated messa
ijuma commented on a change in pull request #9643:
URL: https://github.com/apache/kafka/pull/9643#discussion_r529585355
##
File path: core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
##
@@ -151,21 +149,22 @@ object ConsumerGroupCommand extends Logging {
private[adm
ijuma merged pull request #9645:
URL: https://github.com/apache/kafka/pull/9645
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
ijuma commented on pull request #9645:
URL: https://github.com/apache/kafka/pull/9645#issuecomment-733001614
JDK 8 and 15 builds passed. JDK 11 had one flaky unrelated failure:
`org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest.shouldDoStreamTabl
cadonna commented on a change in pull request #9615:
URL: https://github.com/apache/kafka/pull/9615#discussion_r529461975
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java
##
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apac
dengziming commented on pull request #9639:
URL: https://github.com/apache/kafka/pull/9639#issuecomment-732863217
ping @hachikuji to have a look.
This is an automated message from the Apache Git Service.
To respond to the mes
dengziming opened a new pull request #9649:
URL: https://github.com/apache/kafka/pull/9649
The content of the 3 top-level errors are identical, just merge them.
This is an automated message from the Apache Git Service.
To res
tombentley commented on pull request #9644:
URL: https://github.com/apache/kafka/pull/9644#issuecomment-732818451
@chia7712 current behaviour:
cadonna commented on a change in pull request #9614:
URL: https://github.com/apache/kafka/pull/9614#discussion_r529313022
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java
##
@@ -214,6 +215,20 @@ public RocksDBMetr
chia7712 commented on a change in pull request #9643:
URL: https://github.com/apache/kafka/pull/9643#discussion_r529325622
##
File path: core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
##
@@ -151,21 +149,22 @@ object ConsumerGroupCommand extends Logging {
private[
cadonna commented on a change in pull request #9609:
URL: https://github.com/apache/kafka/pull/9609#discussion_r528847393
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/SourceGraphNode.java
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apach
cadonna commented on a change in pull request #9648:
URL: https://github.com/apache/kafka/pull/9648#discussion_r529280072
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java
##
@@ -149,24 +149,30 @@ public boolean hasPersiste
[
https://issues.apache.org/jira/browse/KAFKA-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shao Wang updated KAFKA-10763:
--
Description:
In our production environment, upon start two KafkaConnect workers, during the
first cou
[
https://issues.apache.org/jira/browse/KAFKA-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shao Wang updated KAFKA-10763:
--
Description:
In our production environment, upon start two KafkaConnect workers, during the
first cou
Shao Wang created KAFKA-10763:
-
Summary: Task already exists error on same worker due to skip
removal of tasks
Key: KAFKA-10763
URL: https://issues.apache.org/jira/browse/KAFKA-10763
Project: Kafka
chia7712 commented on pull request #7409:
URL: https://github.com/apache/kafka/pull/7409#issuecomment-732732168
@ijuma Is this still active? All requests/responses are using auto-generated
protocol so it is time to get rid of `Struct` from serialization. If you are
busy with other works, I
74 matches
Mail list logo
