dajac commented on pull request #11726:
URL: https://github.com/apache/kafka/pull/11726#issuecomment-1027677422
Good catch! It seems that we forgot it in
https://github.com/apache/kafka/commit/53ca52f855e903907378188d29224b3f9cefa6cb.
Have you tried to add a unit test for the bug?
--
Th
dongjinleekr commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1027702595
@Indupa I'm sorry. There was a mistake rebasing onto 2.8.1. You can see the
updated patch with built tarball
[here](https://github.com/dongjinleekr/kafka/releases/tag/2.8.1%
Indupa commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1027741356
Thank you so much @dongjinleekr . Let me try to apply a patch and build.Will
update you
--
This is an automated message from the Apache Git Service.
To respond to the messag
cadonna commented on pull request #11690:
URL: https://github.com/apache/kafka/pull/11690#issuecomment-1027763171
Failing test are unrelated:
```
Build / JDK 11 and Scala 2.13 / kafka.admin.LeaderElectionCommandTest.[1]
Type=Raft, Name=testTopicPartition, Security=PLAINTEXT
Build /
cadonna merged pull request #11690:
URL: https://github.com/apache/kafka/pull/11690
--
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: jira-unsubscr.
HyunSangHan commented on pull request #11418:
URL: https://github.com/apache/kafka/pull/11418#issuecomment-1027773412
Can someone look at 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
URL above to go
[
https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-13599.
---
Resolution: Resolved
> Upgrade RocksDB to 6.27.3
> -
>
>
cadonna commented on pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#issuecomment-1027802506
@vamossagar12 Can we close this PR and the corresponding ticket since it
seems we decided to look for a more complete solution?
--
This is an automated message from the Apac
dengziming commented on pull request #11726:
URL: https://github.com/apache/kafka/pull/11726#issuecomment-1027842174
@dajac , Yes, I added a unit test for this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ulrik updated KAFKA-13638:
--
Description:
I have a topology where I stream messages from an input topic, transform the
message to multiple
Ulrik created KAFKA-13638:
-
Summary: Slow KTable update when forwarding multiple values from
transformer
Key: KAFKA-13638
URL: https://issues.apache.org/jira/browse/KAFKA-13638
Project: Kafka
Issue
dajac commented on a change in pull request #11726:
URL: https://github.com/apache/kafka/pull/11726#discussion_r797572591
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
##
@@ -2948,6 +2948,64 @@ public void testAssignorNameConflict
cadonna commented on a change in pull request #11712:
URL: https://github.com/apache/kafka/pull/11712#discussion_r797611602
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java
##
@@ -270,6 +278,23 @@ Task task(final TaskId taskId) {
ijuma merged pull request #11518:
URL: https://github.com/apache/kafka/pull/11518
--
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: jira-unsubscr...
ijuma merged pull request #11717:
URL: https://github.com/apache/kafka/pull/11717
--
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: jira-unsubscr...
ijuma merged pull request #11669:
URL: https://github.com/apache/kafka/pull/11669
--
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: jira-unsubscr...
jlprat commented on pull request #11518:
URL: https://github.com/apache/kafka/pull/11518#issuecomment-1027974346
Thanks @ijuma
--
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 comme
ijuma merged pull request #11619:
URL: https://github.com/apache/kafka/pull/11619
--
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: jira-unsubscr...
ijuma merged pull request #11618:
URL: https://github.com/apache/kafka/pull/11618
--
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: jira-unsubscr...
jonathan-albrecht-ibm commented on pull request #11690:
URL: https://github.com/apache/kafka/pull/11690#issuecomment-1027990865
Thanks @cadonna!
--
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
ijuma commented on pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#issuecomment-1027997296
Thanks for the detailed analysis! Note that JMH 1.34
(https://mail.openjdk.java.net/pipermail/jmh-dev/2021-December/003406.html) has
support for much cheaper blackholes if execut
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ulrik updated KAFKA-13638:
--
Description:
I have a topology where I stream messages from an input topic, transform the
message to multiple
[
https://issues.apache.org/jira/browse/KAFKA-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485868#comment-17485868
]
Fabrice Bauzac-Stehly commented on KAFKA-13534:
---
Shouldn't this ticket be
[
https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485878#comment-17485878
]
Fabrice Bauzac-Stehly commented on KAFKA-9366:
--
https://kafka.apache.org/cve
[
https://issues.apache.org/jira/browse/KAFKA-13626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485879#comment-17485879
]
Kvicii.Yu commented on KAFKA-13626:
---
[~haeuserd]
Thanks for your report, but what e
[
https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485878#comment-17485878
]
Fabrice Bauzac-Stehly edited comment on KAFKA-9366 at 2/2/22, 3:17 PM:
[
https://issues.apache.org/jira/browse/KAFKA-9366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17485878#comment-17485878
]
Fabrice Bauzac-Stehly edited comment on KAFKA-9366 at 2/2/22, 3:17 PM:
Kvicii opened a new pull request #11727:
URL: https://github.com/apache/kafka/pull/11727
*More detailed description of your change,
fix AbstractStickyAssignor doc
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify t
wcarlson5 commented on a change in pull request #11712:
URL: https://github.com/apache/kafka/pull/11712#discussion_r797772309
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java
##
@@ -270,6 +278,23 @@ Task task(final TaskId taskId) {
Indupa commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1028142767
Hi @dongjinleekr , need one input from you.
Is All dependencies of log4j 1.x is completely Removed in this
Patch?, I could see,still dependency on log4j_1.2.17 i
Indupa edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1028142767
Hi @dongjinleekr ,I could able to build latest patch and also need one input
from you.
Is All dependencies of log4j 1.x is completely Removed in this
Patch..
Indupa edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1028142767
Hi @dongjinleekr ,I could able to build latest patch and also need one input
from you.
Is All dependencies of log4j 1.x is completely Removed in this
Patch..
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r797845874
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/TopologyConfig.java
##
@@ -116,14 +123,30 @@ public T
vamossagar12 commented on a change in pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#discussion_r797848030
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -329,7 +330,7 @@ private TopologyTestDriver(fi
cmccabe commented on a change in pull request #11689:
URL: https://github.com/apache/kafka/pull/11689#discussion_r797873026
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -1506,6 +1508,46 @@ public void testNullTopicName() {
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486001#comment-17486001
]
Matthias J. Sax commented on KAFKA-13638:
-
We did update the RocksDB version in
Sergey Ivanov created KAFKA-13639:
-
Summary: NotEnoughReplicasException for __consumer_offsets topic
due to out of order offset
Key: KAFKA-13639
URL: https://issues.apache.org/jira/browse/KAFKA-13639
philipnee commented on a change in pull request #11689:
URL: https://github.com/apache/kafka/pull/11689#discussion_r797884312
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/KafkaProducerTest.java
##
@@ -1506,6 +1508,46 @@ public void testNullTopicName()
[
https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13633:
Labels: kip (was: )
> Merging multiple KStreams in one operation
> --
[
https://issues.apache.org/jira/browse/KAFKA-13633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486002#comment-17486002
]
Matthias J. Sax commented on KAFKA-13633:
-
Thanks! Will try to review the KIP so
[
https://issues.apache.org/jira/browse/KAFKA-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486005#comment-17486005
]
Sergey Ivanov commented on KAFKA-13639:
---
We found mail thread which describe the s
jasonk000 commented on pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#issuecomment-1028229086
Good spot on jmh 1.34, TIL! Here's a result from a re-run
```
jkoch@jkoch:~/code/kafka$ java -version
openjdk version "17.0.1" 2021-10-19
OpenJDK Runtime Environmen
jasonk000 edited a comment on pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#issuecomment-1028229086
Good spot on jmh 1.34, TIL! Here's a result from a re-run
```
jkoch@jkoch:~/code/kafka$ java -version
openjdk version "17.0.1" 2021-10-19
OpenJDK Runtime Env
[
https://issues.apache.org/jira/browse/KAFKA-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486005#comment-17486005
]
Sergey Ivanov edited comment on KAFKA-13639 at 2/2/22, 6:31 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486011#comment-17486011
]
Sergey Ivanov commented on KAFKA-12494:
---
Hi all,
We faced the similar issue on ou
azhur closed pull request #11728:
URL: https://github.com/apache/kafka/pull/11728
--
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: jira-unsubscr...
guozhangwang commented on pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#issuecomment-1028264508
@ableegoldman @mjsax My read on the code is that we only need to change the
TopologyTestDriver, while the first place seems fine to me. Did I miss anything?
--
This is a
[
https://issues.apache.org/jira/browse/KAFKA-13639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486005#comment-17486005
]
Sergey Ivanov edited comment on KAFKA-13639 at 2/2/22, 7:04 PM:
--
cmccabe opened a new pull request #11729:
URL: https://github.com/apache/kafka/pull/11729
The current error message suggests that controller.listener.names is a
replacement for
control.plane.listener.name. This is incorrect since these configurations
have very different
functions. Th
kirktrue commented on pull request #11627:
URL: https://github.com/apache/kafka/pull/11627#issuecomment-1028296460
This looks pretty straightforward to me, though I'm still learning the
consumer client piece.
--
This is an automated message from the Apache Git Service.
To respond to the
hachikuji merged pull request #11725:
URL: https://github.com/apache/kafka/pull/11725
--
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: jira-unsubsc
[
https://issues.apache.org/jira/browse/KAFKA-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13221.
-
Fix Version/s: 3.2.0
Resolution: Fixed
> Add metric for `PartitionsWithLateTransa
artemlivshits commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r797932888
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double valu
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798002944
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value, B
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798002944
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value, B
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798002944
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double value, B
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486102#comment-17486102
]
Ulrik commented on KAFKA-13638:
---
[~mjsax] I can confirm that using an in-memory store work
ijuma commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798019651
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Software F
Colin McCabe created KAFKA-13640:
Summary: Implement final broker heartbeat in kraft
Key: KAFKA-13640
URL: https://issues.apache.org/jira/browse/KAFKA-13640
Project: Kafka
Issue Type: Improve
ijuma merged pull request #11656:
URL: https://github.com/apache/kafka/pull/11656
--
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: jira-unsubscr...
jasonk000 commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798077165
##
File path:
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java
##
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Softwa
artemlivshits commented on a change in pull request #11721:
URL: https://github.com/apache/kafka/pull/11721#discussion_r798094178
##
File path: clients/src/main/java/org/apache/kafka/common/utils/ByteUtils.java
##
@@ -386,18 +386,39 @@ public static void writeDouble(double valu
cmccabe commented on pull request #11689:
URL: https://github.com/apache/kafka/pull/11689#issuecomment-1028467009
test failures are not related.
--
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
cmccabe merged pull request #11689:
URL: https://github.com/apache/kafka/pull/11689
--
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: jira-unsubscr.
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486177#comment-17486177
]
Matthias J. Sax commented on KAFKA-13638:
-
Seems this does not explain much yet,
mjsax commented on pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#issuecomment-1028497889
I did not dig into the details myself. Anyway, might be better to discuss on
the new PR?
--
This is an automated message from the Apache Git Service.
To respond to the message,
stan-confluent opened a new pull request #11730:
URL: https://github.com/apache/kafka/pull/11730
Ducktape 0.7.17 locked a couple of dependencies to their last py2 compatible
versions - this ensures more or less stable python 2 builds for kafkatest
(until some other package breaks it).
S
stan-confluent commented on pull request #11730:
URL: https://github.com/apache/kafka/pull/11730#issuecomment-102874
@cmccabe @ijuma @ewencp can you folks please take a look and/or suggest who
else should be on the approvers list?
--
This is an automated message from the Apache Git S
dengziming commented on a change in pull request #11726:
URL: https://github.com/apache/kafka/pull/11726#discussion_r798204734
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
##
@@ -2948,6 +2948,64 @@ public void testAssignorNameCon
dengziming commented on a change in pull request #11726:
URL: https://github.com/apache/kafka/pull/11726#discussion_r798205426
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java
##
@@ -2948,6 +2948,64 @@ public void testAssignorNameCon
Indupa edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1028142767
Hi @dongjinleekr ,I could able to build latest patch and also need one input
from you.
Is All dependencies of log4j 1.x is completely Removed in this
Patch..
Mohammad Yousuf Minhaj Zia created KAFKA-13641:
--
Summary: Kafka Streams Scala: Add `Option` to `ValueJoiner`
parameters
Key: KAFKA-13641
URL: https://issues.apache.org/jira/browse/KAFKA-13641
[
https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486257#comment-17486257
]
Ulrik commented on KAFKA-13638:
---
I tried the following combination of versions:
* strea
73 matches
Mail list logo
