[
https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477048#comment-17477048
]
David Jacot commented on KAFKA-13592:
-
[~Kvicii] Of course! Go for it. I think that
dajac merged pull request #11680:
URL: https://github.com/apache/kafka/pull/11680
--
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-10892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477071#comment-17477071
]
Daan Gerits commented on KAFKA-10892:
-
I hijacked this issues to use it to use it as
vpapavas opened a new pull request #11682:
URL: https://github.com/apache/kafka/pull/11682
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testin
dajac commented on pull request #11665:
URL: https://github.com/apache/kafka/pull/11665#issuecomment-1014389443
@jolshan I have found another way to fix the issue and that one keeps
asserting the topic ID. Let me know what you think.
--
This is an automated message from the Apache Git Se
viktorsomogyi commented on a change in pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#discussion_r783871962
##
File path: core/src/main/scala/kafka/utils/Log4jController.scala
##
@@ -17,83 +17,89 @@
package kafka.utils
+import org.apache.logging.log4j.c
mimaison commented on pull request #11371:
URL: https://github.com/apache/kafka/pull/11371#issuecomment-1014401089
@akatona84 Sorry this PR felt through the cracks. If I remember correctly,
last time I was looking at it I had trouble replicating the issue. Can you
provide steps to reproduc
viktorsomogyi commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1014401948
@vlsi you can use other log libraries today as well. The other day I tried
out logback runtime (on the broker side) and it works well. All you need is to
include logback (o
viktorsomogyi edited a comment on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-1014401948
@vlsi you can use other log libraries today as well. The other day I tried
out logback runtime (on the broker side) and it works well. All you need is to
include log
satishd commented on a change in pull request #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r785875887
##
File path: core/src/main/scala/kafka/server/ReplicaFetcherThread.scala
##
@@ -386,11 +397,109 @@ class ReplicaFetcherThread(name: String,
}
/**
Ge opened a new pull request #11683:
URL: https://github.com/apache/kafka/pull/11683
Without this patch RecordQueue just skips records that failed to
deserialize when DeserializationExceptionHandler is set to
LogAndContinueExceptionHandler. This way, if the entire stream consists
Willian Dallastella created KAFKA-13597:
---
Summary: Memory leak with kafka-clients 3.0.0
Key: KAFKA-13597
URL: https://issues.apache.org/jira/browse/KAFKA-13597
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
cadonna commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r785917415
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -488,23 +492,37 @@ private boolean c
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477218#comment-17477218
]
Luke Chen commented on KAFKA-13597:
---
[~willian.wd] , thanks for reporting the issue. D
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477222#comment-17477222
]
Luke Chen commented on KAFKA-13597:
---
And, please also provide the producer config. Tha
[
https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477226#comment-17477226
]
Maksim Zinal commented on KAFKA-2170:
-
I've created a quick patch which seems to fix
[
https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477227#comment-17477227
]
Maksim Zinal commented on KAFKA-1194:
-
Duplicating my comment from KAFKA-2170 here.
[
https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477226#comment-17477226
]
Maksim Zinal edited comment on KAFKA-2170 at 1/17/22, 1:59 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477227#comment-17477227
]
Maksim Zinal edited comment on KAFKA-1194 at 1/17/22, 1:59 PM:
akatona84 commented on pull request #11371:
URL: https://github.com/apache/kafka/pull/11371#issuecomment-1014579238
@mimaison , np, thx for following up :)
steps to fail:
1. create - for example - an environment variable config provider, create a
jar from it
2. put it into the
dongjinleekr commented on a change in pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#discussion_r786045157
##
File path: core/src/test/scala/unit/kafka/utils/LogCaptureContext.scala
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477240#comment-17477240
]
Willian Dallastella commented on KAFKA-13597:
-
[~showuon] I just tested with
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Willian Dallastella updated KAFKA-13597:
Description:
I'm having this issue reported here:
[https://github.com/spring-proj
dongjinleekr commented on a change in pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#discussion_r786067964
##
File path: streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java
##
@@ -102,6 +103,7 @@
import static org.junit.Assert.fail;
@Run
patrickstuedi commented on a change in pull request #11682:
URL: https://github.com/apache/kafka/pull/11682#discussion_r786116191
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
##
@@ -83,10 +89,64 @@ public void init(fina
[
https://issues.apache.org/jira/browse/KAFKA-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
highluck resolved KAFKA-10283.
--
Resolution: Fixed
> Consolidate client-level and consumer-level assignment within ClientState
> --
highluck opened a new pull request #11684:
URL: https://github.com/apache/kafka/pull/11684
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testin
Ge commented on pull request #11683:
URL: https://github.com/apache/kafka/pull/11683#issuecomment-1014719355
The test failure,
https://github.com/apache/kafka/pull/11683/checks?check_run_id=4842442884, does
not seem related.
--
This is an automated message from the Apache Git Servic
[
https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksandr Sorokoumov reassigned KAFKA-6502:
---
Assignee: Aleksandr Sorokoumov (was: Jagadesh Adireddi)
> Kafka streams des
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477240#comment-17477240
]
Willian Dallastella edited comment on KAFKA-13597 at 1/17/22, 4:36 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-6502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477315#comment-17477315
]
Aleksandr Sorokoumov edited comment on KAFKA-6502 at 1/17/22, 4:37 PM:
vamossagar12 commented on pull request #11424:
URL: https://github.com/apache/kafka/pull/11424#issuecomment-1014741167
hey @guozhangwang , did you get a chance to look at my above comment?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
vamossagar12 commented on pull request #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-1014741899
hi @guozhangwang / @ableegoldman , can we plz decide on an approach on this
one? I can proceed with the changes needed in that case..
--
This is an automated message fro
vamossagar12 commented on a change in pull request #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r786180105
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -292,12 +327,20 @@ public void handleAssignm
shubhamsingh002 opened a new pull request #11685:
URL: https://github.com/apache/kafka/pull/11685
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
[
https://issues.apache.org/jira/browse/KAFKA-13555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-13555:
-
Assignee: Sagar Rao
> Consider number if input topic partitions for task assignment
> -
dajac commented on a change in pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#discussion_r786181034
##
File path: core/src/main/scala/kafka/tools/ConsoleProducer.scala
##
@@ -264,39 +277,89 @@ object ConsoleProducer {
var reader: BufferedReader = null
florin-akermann commented on pull request #11456:
URL: https://github.com/apache/kafka/pull/11456#issuecomment-1014891124
> LGTM! Thanks @florin-akermann for the KIP and PR, this is a nice
improvement to the console producer.
@mimaison Thanks a lot for a the PR review. The whole proc
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r786311430
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/source/SourceConnector.java
##
@@ -28,4 +30,31 @@
protected SourceConnectorContext
C0urante commented on pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#issuecomment-1014923523
Thanks Randall, I've addressed all of your comments either with code changes
or an inline response in the appropriate thread.
I've noted this elsewhere but it bears repe
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r786314621
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java
##
@@ -0,0 +1,507 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477490#comment-17477490
]
Kvicii.Yu commented on KAFKA-13592:
---
[~dajac] I would like to give this a go so that I
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r786341813
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java
##
@@ -0,0 +1,643 @@
+/*
+ * Licensed to the
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r786341813
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java
##
@@ -0,0 +1,643 @@
+/*
+ * Licensed to the
C0urante commented on a change in pull request #10907:
URL: https://github.com/apache/kafka/pull/10907#discussion_r786341813
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java
##
@@ -0,0 +1,643 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/KAFKA-13592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477490#comment-17477490
]
Kvicii.Yu edited comment on KAFKA-13592 at 1/18/22, 1:43 AM:
-
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r786445650
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java
##
@@ -85,24 +86,51 @@ public void setup() {
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r786448672
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -488,23 +492,37 @@ private bool
ableegoldman commented on a change in pull request #11600:
URL: https://github.com/apache/kafka/pull/11600#discussion_r786451847
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java
##
@@ -589,6 +580,52 @@ public void
shou
ableegoldman opened a new pull request #11686:
URL: https://github.com/apache/kafka/pull/11686
Followup to #11600 to invoke the streams exception handler on the
MissingSourceTopicException, without killing/replacing the thread
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/KAFKA-13597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17477621#comment-17477621
]
Luke Chen commented on KAFKA-13597:
---
Thanks for the response. I'll investigate it.
>
56 matches
Mail list logo
