Daniel Urban created KAFKA-14652:
Summary: Improve MM2 logging by adding the flow information to the
context
Key: KAFKA-14652
URL: https://issues.apache.org/jira/browse/KAFKA-14652
Project: Kafka
Schm1tz1 commented on code in PR #12992:
URL: https://github.com/apache/kafka/pull/12992#discussion_r1086368344
##
clients/src/main/java/org/apache/kafka/common/config/provider/EnvVarConfigProvider.java:
##
@@ -0,0 +1,89 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
urbandan commented on code in PR #13137:
URL: https://github.com/apache/kafka/pull/13137#discussion_r1086404484
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/DedicatedMirrorIntegrationTest.java:
##
@@ -0,0 +1,228 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-10586:
-
Issue Type: Task (was: Improvement)
> Full support for distributed mode in dedicated MirrorMake
Daniel Urban created KAFKA-14653:
Summary: MM2 should delay resolving config provider references
Key: KAFKA-14653
URL: https://issues.apache.org/jira/browse/KAFKA-14653
Project: Kafka
Issue T
urbandan opened a new pull request, #13163:
URL: https://github.com/apache/kafka/pull/13163
…esolution properties.
MirrorMakerConfig extends AbstractConfig, which resolves config provider
based references eagerly, construction time. Because of this, Connector
configurations created b
[
https://issues.apache.org/jira/browse/KAFKA-14324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-14324:
--
Fix Version/s: 3.2.4
3.1.3
3.0.3
3.3.2
[
https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680544#comment-17680544
]
Mikael commented on KAFKA-14419:
Hi, sorry about the log delay. Now I finally got around
[
https://issues.apache.org/jira/browse/KAFKA-14419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680544#comment-17680544
]
Mikael edited comment on KAFKA-14419 at 1/25/23 10:35 AM:
--
Hi,
urbandan commented on PR #13163:
URL: https://github.com/apache/kafka/pull/13163#issuecomment-1403439915
@C0urante @viktorsomogyi Can you please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
fvaleri commented on code in PR #13158:
URL: https://github.com/apache/kafka/pull/13158#discussion_r1086613346
##
server-common/src/test/java/org/apache/kafka/server/util/TopicFilterTest.java:
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
[
https://issues.apache.org/jira/browse/KAFKA-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680625#comment-17680625
]
Omnia Ibrahim commented on KAFKA-14525:
---
I would like to help with some of these.
[
https://issues.apache.org/jira/browse/KAFKA-14596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14596:
-
Assignee: Omnia Ibrahim
> Move TopicCommand to tools
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14593:
-
Assignee: Omnia Ibrahim
> Move LeaderElectionCommand to tools
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14578:
-
Assignee: Omnia Ibrahim
> Move ConsumerPerformance to tools
> -
[
https://issues.apache.org/jira/browse/KAFKA-14577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14577:
-
Assignee: Omnia Ibrahim
> Move ConsoleProducer to tools
> -
[
https://issues.apache.org/jira/browse/KAFKA-14587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14587:
-
Assignee: Omnia Ibrahim
> Move AclCommand to tools
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14588:
-
Assignee: Omnia Ibrahim
> Move ConfigCommand to tools
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14589:
-
Assignee: Omnia Ibrahim
> Move ConsumerGroupCommand to tools
>
[
https://issues.apache.org/jira/browse/KAFKA-14595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14595:
-
Assignee: Omnia Ibrahim
> Move ReassignPartitionsCommand to tools
> ---
fvaleri commented on code in PR #13136:
URL: https://github.com/apache/kafka/pull/13136#discussion_r1086675903
##
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala:
##
@@ -801,21 +801,15 @@ object ConsumerGroupCommand extends Logging {
partitionsToReset.map { t
[
https://issues.apache.org/jira/browse/KAFKA-14579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim reassigned KAFKA-14579:
-
Assignee: Omnia Ibrahim
> Move DumpLogSegments to tools
> -
fvaleri commented on code in PR #13136:
URL: https://github.com/apache/kafka/pull/13136#discussion_r1086694567
##
tools/src/main/java/org/apache/kafka/tools/JmxCommand.java:
##
@@ -0,0 +1,441 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contr
fvaleri commented on PR #13136:
URL: https://github.com/apache/kafka/pull/13136#issuecomment-1403712199
Thanks @mimaison.
I addressed all your comments and now working on the test suite.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-14525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680637#comment-17680637
]
Federico Valeri commented on KAFKA-14525:
-
Thanks [~omnia_h_ibrahim].
FYI, I cr
[
https://issues.apache.org/jira/browse/KAFKA-5072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680707#comment-17680707
]
Barak commented on KAFKA-5072:
--
This would be very useful.
> Kafka topics should allow cust
hachikuji merged PR #13140:
URL: https://github.com/apache/kafka/pull/13140
--
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...@kafka.apach
[
https://issues.apache.org/jira/browse/KAFKA-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-14644.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Process should stop after failure in raf
Greg Harris created KAFKA-14654:
---
Summary: Connectors have incorrect Thread Context Classloader
during initialization
Key: KAFKA-14654
URL: https://issues.apache.org/jira/browse/KAFKA-14654
Project: Kaf
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1086981346
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -300,9 +301,13 @@ void runOnce() {
try {
transacti
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1086981869
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java:
##
@@ -300,9 +301,13 @@ void runOnce() {
try {
transacti
lucasbru opened a new pull request, #13164:
URL: https://github.com/apache/kafka/pull/13164
Make sure no scaladoc warnings are emitted from the streams-scala project
build. We cannot fully fix all scaladoc warnings due to limitations of the
scaladoc tool, so this is a best-effort attempt at
gharris1727 opened a new pull request, #13165:
URL: https://github.com/apache/kafka/pull/13165
The scanPluginPath -> getPluginDesc -> versionFor code path instantiates
connectors in order to evaluate their version() method. This is the first call
to initialize these classes, and so performs
jolshan commented on code in PR #12149:
URL: https://github.com/apache/kafka/pull/12149#discussion_r1086992753
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -155,7 +155,7 @@ private enum State {
private boolean isTra
mjsax commented on code in PR #13164:
URL: https://github.com/apache/kafka/pull/13164#discussion_r1087040518
##
streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/Consumed.scala:
##
@@ -43,7 +43,7 @@ object Consumed {
ConsumedJ.`with`(keySerde, valu
cmccabe commented on PR #13098:
URL: https://github.com/apache/kafka/pull/13098#issuecomment-1404230760
Looks like something exited the Jenkins process. Rerunning.
```
[2023-01-24T22ː55ː33.723Z] Execution failed for task 'ːcoreːintegrationTest'.
[2023-01-24T22ː55ː33.723Z] > Process '
kirktrue opened a new pull request, #13166:
URL: https://github.com/apache/kafka/pull/13166
Removes logging of the HTTP response directly in all known cases to prevent
potentially logging access tokens.
Reviewers: Sushant Mahajan , Rajini Sivaram
(cherry picked from commit bc1ce
jsancio commented on PR #13154:
URL: https://github.com/apache/kafka/pull/13154#issuecomment-1404366998
Merging. Unrelated test failures.
--
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 speci
[
https://issues.apache.org/jira/browse/KAFKA-14553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14553:
---
Fix Version/s: 3.4.0
> RecordAccumulator hangs in infinite NOP loop
> --
jsancio merged PR #13154:
URL: https://github.com/apache/kafka/pull/13154
--
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...@kafka.apache.
[
https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680840#comment-17680840
]
Matthias J. Sax commented on KAFKA-14646:
-
Could be – let me sync with Alex who
guozhangwang opened a new pull request, #13167:
URL: https://github.com/apache/kafka/pull/13167
1) The major fix: synchronize access to tasks inside task manager.
2) Clarify on func names of StreamThread that maybe triggered outside the
StreamThread.
3) Minor cleanups.
### Commi
guozhangwang commented on PR #13167:
URL: https://github.com/apache/kafka/pull/13167#issuecomment-1404437326
ping @cadonna for review.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680857#comment-17680857
]
Matthias J. Sax commented on KAFKA-14646:
-
Ok. Talked to Alex and he quickly fig
[
https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-14646:
Affects Version/s: 3.3.1
3.3.0
> SubscriptionWrapper is of an incom
[
https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13769:
Fix Version/s: 3.4.0
3.3.3
(was: 3.3.0)
> KTable
[
https://issues.apache.org/jira/browse/KAFKA-13769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680858#comment-17680858
]
Matthias J. Sax commented on KAFKA-13769:
-
I just updated fixed version from 3.0
[
https://issues.apache.org/jira/browse/KAFKA-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14646.
-
Fix Version/s: 3.4.0
3.3.3
Resolution: Fixed
> SubscriptionWra
vamossagar12 commented on PR #13095:
URL: https://github.com/apache/kafka/pull/13095#issuecomment-1404639472
hi @mimaison would you plz review this PR whenever you get the chance? It's
already approved by @fvaleri . Thanks
--
This is an automated message from the Apache Git Service.
To re
vamossagar12 commented on code in PR #13158:
URL: https://github.com/apache/kafka/pull/13158#discussion_r1087508896
##
server-common/src/main/java/org/apache/kafka/server/util/TopicFilter.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
50 matches
Mail list logo
