[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413480#comment-17413480
]
Christo Lolov commented on KAFKA-12994:
---
[~ableegoldman] Thank you for the comment
[
https://issues.apache.org/jira/browse/KAFKA-13227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413479#comment-17413479
]
Christo Lolov commented on KAFKA-13227:
---
[~hachikuji] Apologies for the delay, I w
dengziming opened a new pull request #11321:
URL: https://github.com/apache/kafka/pull/11321
*More detailed description of your change*
Replace EasyMock with Mockito in connect:basic-auth-extension
--
This is an automated message from the Apache Git Service.
To respond to the messa
satishd commented on pull request #11058:
URL: https://github.com/apache/kafka/pull/11058#issuecomment-917351522
@junrao Rebased the PR and resolved the conflicts, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
cmccabe merged pull request #11313:
URL: https://github.com/apache/kafka/pull/11313
--
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.
cmccabe commented on a change in pull request #11312:
URL: https://github.com/apache/kafka/pull/11312#discussion_r706509007
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1385,10 +1385,22 @@ object KafkaConfig {
}
if (maybeSensitive) Password.
cmccabe commented on a change in pull request #11312:
URL: https://github.com/apache/kafka/pull/11312#discussion_r706507377
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1385,10 +1385,22 @@ object KafkaConfig {
}
if (maybeSensitive) Password.
cmccabe commented on a change in pull request #11312:
URL: https://github.com/apache/kafka/pull/11312#discussion_r706506964
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1385,10 +1385,22 @@ object KafkaConfig {
}
if (maybeSensitive) Password.
[
https://issues.apache.org/jira/browse/KAFKA-7408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413424#comment-17413424
]
Jose Armando Garcia Sancio commented on KAFKA-7408:
---
[~hachikuji] can y
cmccabe opened a new pull request #11320:
URL: https://github.com/apache/kafka/pull/11320
The ReplicaManager, LogManager, and KafkaApis class all have many
constructor parameters. It is often difficult to add or remove a
parameter, since there are so many locations that need to be upda
hachikuji commented on a change in pull request #11312:
URL: https://github.com/apache/kafka/pull/11312#discussion_r706502119
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1385,10 +1385,22 @@ object KafkaConfig {
}
if (maybeSensitive) Passwor
[
https://issues.apache.org/jira/browse/KAFKA-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8116:
---
Fix Version/s: 4.0.0
> Add Kafka Streams archetype for Java11
> -
[
https://issues.apache.org/jira/browse/KAFKA-13289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413408#comment-17413408
]
Matthias J. Sax commented on KAFKA-13289:
-
I guess that the repartition topic co
[
https://issues.apache.org/jira/browse/KAFKA-13290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413405#comment-17413405
]
Matthias J. Sax commented on KAFKA-13290:
-
Your observation is behavior by-desig
[
https://issues.apache.org/jira/browse/KAFKA-13290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-13290.
-
Resolution: Not A Problem
> My timeWindows last aggregated message never emit until a ne
[
https://issues.apache.org/jira/browse/KAFKA-13288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-13288.
-
Resolution: Fixed
> Transaction find-hanging command with --broker-id excludes internal
hachikuji merged pull request #11319:
URL: https://github.com/apache/kafka/pull/11319
--
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-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413395#comment-17413395
]
Rajini Sivaram edited comment on KAFKA-10338 at 9/10/21, 9:27 PM:
[
https://issues.apache.org/jira/browse/KAFKA-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413395#comment-17413395
]
Rajini Sivaram commented on KAFKA-10338:
[~teabot] We currently don't have a way
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r706478220
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -198,8 +199,23 @@ private[log] class LogCleanerManager(val logDirs:
Seq[Fil
mumrah commented on a change in pull request #11312:
URL: https://github.com/apache/kafka/pull/11312#discussion_r706419226
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1385,10 +1385,22 @@ object KafkaConfig {
}
if (maybeSensitive) Password.H
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413335#comment-17413335
]
Guozhang Wang commented on KAFKA-13272:
---
I looked into the source code and I have
cmccabe commented on a change in pull request #11313:
URL: https://github.com/apache/kafka/pull/11313#discussion_r706387699
##
File path:
core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala
##
@@ -977,6 +977,9 @@ class GroupMetadataManager(brokerId: Int,
hachikuji opened a new pull request #11319:
URL: https://github.com/apache/kafka/pull/11319
This patch ensures that internal topics are included when searching for
hanging transactions with the `--broker-id` argument in `kafka-transactions.sh`.
### Committer Checklist (excluded from
guozhangwang commented on pull request #10798:
URL: https://github.com/apache/kafka/pull/10798#issuecomment-917118246
Hi @vamossagar12 Thanks again for your patience! I know it has been dragging
a bit long, and I had some discussions with @cadonna and @vamossagar12
regarding how we can mov
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13286:
--
Description:
Kafka Streams state store is built in hierarchical layers as metered -> cached
-
[
https://issues.apache.org/jira/browse/KAFKA-13286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13286:
--
Description:
Kafka Streams state store is built in hierarchical layers as metered -> cached
-
[
https://issues.apache.org/jira/browse/KAFKA-13288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413278#comment-17413278
]
Jason Gustafson commented on KAFKA-13288:
-
Note that it is still possible to use
teabot commented on pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#issuecomment-916994728
How is PEM certificate renewal possible on the producer/consumer client? Is
this documented anywhere?
--
This is an automated message from the Apache Git Service.
To respond to t
[
https://issues.apache.org/jira/browse/KAFKA-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413243#comment-17413243
]
Elliot West edited comment on KAFKA-10338 at 9/10/21, 3:29 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413243#comment-17413243
]
Elliot West commented on KAFKA-10338:
-
How is PEM certificate renewal possible on th
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot edited comment on KAFKA-13272 at 9/10/21, 3:17 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Zhou updated KAFKA-13290:
---
Description:
I have a Kafka stream event processing code which aggregates 1 minutes data.
It works
[
https://issues.apache.org/jira/browse/KAFKA-13290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steve Zhou updated KAFKA-13290:
---
Description:
I have a stream code which aggregate 1 minutes data.
It works as expected if data com
Steve Zhou created KAFKA-13290:
--
Summary: My timeWindows last aggregated message never emit until a
new message coming
Key: KAFKA-13290
URL: https://issues.apache.org/jira/browse/KAFKA-13290
Project: Ka
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot edited comment on KAFKA-13272 at 9/10/21, 1:57 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot edited comment on KAFKA-13272 at 9/10/21, 1:57 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot edited comment on KAFKA-13272 at 9/10/21, 1:56 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot edited comment on KAFKA-13272 at 9/10/21, 1:55 PM:
[
https://issues.apache.org/jira/browse/KAFKA-13272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413197#comment-17413197
]
F Méthot commented on KAFKA-13272:
--
Hi [~guozhang] Thanks for your feedback.
We were p
chia7712 commented on a change in pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#discussion_r706140746
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorderTest.java
##
@@ -378,261 +347,189 @@ public v
showuon commented on pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#issuecomment-916861911
@patrickstuedi , yes, the fix PR
(https://github.com/apache/kafka/pull/11292) is under reviewing (should be
close). Thank you.
--
This is an automated message from the Apache
patrickstuedi commented on pull request #11227:
URL: https://github.com/apache/kafka/pull/11227#issuecomment-916855214
@showuon Any new updates on 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 above to
[
https://issues.apache.org/jira/browse/KAFKA-13128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413135#comment-17413135
]
Bruno Cadonna commented on KAFKA-13128:
---
And also here:
[https://ci-builds.apache.
cadonna commented on pull request #11317:
URL: https://github.com/apache/kafka/pull/11317#issuecomment-916843098
I even found the PR:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-11250/9/
--
This is an automated message from the Apache Git Service.
To respond to the messa
cadonna commented on pull request #11317:
URL: https://github.com/apache/kafka/pull/11317#issuecomment-916842108
@ableegoldman I think I have already seen this specific failure in another
PR. But I agree with you that we need to keep an eye on this.
--
This is an automated message from t
ableegoldman commented on a change in pull request #11272:
URL: https://github.com/apache/kafka/pull/11272#discussion_r706092654
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -359,15 +362,24 @@ public final
[
https://issues.apache.org/jira/browse/KAFKA-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413090#comment-17413090
]
Ahmed Toumi commented on KAFKA-13014:
-
Thank you [~mjsax], I think that the guy that
wycc commented on pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#issuecomment-916776585
@ijuma I think I survived this round of reviews.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
wycc commented on pull request #10976:
URL: https://github.com/apache/kafka/pull/10976#issuecomment-916775979
@chia7712 I think I have solved most of the problems, except merger
`setUpMetricsStubMock`.
In order to avoid existing static mock registration problem caused by
repeatedly
ableegoldman commented on a change in pull request #11272:
URL: https://github.com/apache/kafka/pull/11272#discussion_r706014148
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java
##
@@ -359,15 +362,24 @@ public final
ableegoldman commented on a change in pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#discussion_r706010750
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java
##
@@ -292,13 +408,46 @@ public V fetch(final K
[
https://issues.apache.org/jira/browse/KAFKA-12774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12774:
Fix Version/s: (was: 2.8.1)
> kafka-streams 2.8: logging in uncaught-exceptionhandler doesn't
[
https://issues.apache.org/jira/browse/KAFKA-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12622:
Fix Version/s: (was: 2.8.1)
3.1.0
> Automate LICENSE file validation
>
[
https://issues.apache.org/jira/browse/KAFKA-13164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-13164:
Fix Version/s: (was: 2.8.1)
> State store is attached to wrong node in the Kafka Streams topol
[
https://issues.apache.org/jira/browse/KAFKA-12644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-12644:
Fix Version/s: (was: 2.8.1)
> Add Missing Class-Level Javadoc to Descendants of
> org.apache.
[
https://issues.apache.org/jira/browse/KAFKA-13256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413010#comment-17413010
]
Mickael Maison commented on KAFKA-13256:
While this does not affect Apache Kafka
57 matches
Mail list logo
