Hi,
It looks like you found a bug.
Feel free to open a pull request if you want to fix it, or at least
open a Jira to report the issue.
Thanks,
Mickael
On Thu, Nov 6, 2025 at 12:38 AM dhidah riadh wrote:
>
> Hi Kafka community,
>
> I’m running MirrorMaker 2 (Kafka Connect, Kafk
Hi Kafka community,
I’m running MirrorMaker 2 (Kafka Connect, Kafka 4.1.0) and noticed a
recurring NullPointerException in MirrorSourceMetrics during high load:
exactly here :
https://github.com/apache/kafka/blob/61e63f12635ad6ff50c5a4e54d51d725ae82d11a/connect/mirror/src/main/java/org/apache
rote:
>>>>
>>>>> Hi Anton,
>>>>>
>>>>> I'm +1 (binding), thanks for the KIP!
>>>>>
>>>>> Yash
>>>>>
>>>>> On Thu, Sep 4, 2025 at 10:24 AM Anton Liauchuk
>>>>> wrote:
>>>>>
>>>>> > hi
>>>>> >
>>>>> > I would like to start a vote on *KIP-1209: Add configuration to
>>>>> control
>>>>> > internal topic creation in Kafka Connect*
>>>>> >
>>>>> > KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
>>>>> > Discussion thread:
>>>>> > https://lists.apache.org/thread/l89rzzm0jd4ml7xx66mkxfztst281so7
>>>>> >
>>>>>
>>>>
t;>
>>>> Hi Anton,
>>>>
>>>> I'm +1 (binding), thanks for the KIP!
>>>>
>>>> Yash
>>>>
>>>> On Thu, Sep 4, 2025 at 10:24 AM Anton Liauchuk
>>>> wrote:
>>>>
>>>> > hi
t;> wrote:
>>>
>>> > hi
>>> >
>>> > I would like to start a vote on *KIP-1209: Add configuration to control
>>> > internal topic creation in Kafka Connect*
>>> >
>>> > KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
>>> > Discussion thread:
>>> > https://lists.apache.org/thread/l89rzzm0jd4ml7xx66mkxfztst281so7
>>> >
>>>
>>
[
https://issues.apache.org/jira/browse/KAFKA-19758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-19758.
Resolution: Fixed
> Weird behavior on Kafka Connect 4.1 class load
: [email protected]
Subject: Weird behavior on Kafka Connect class loading
You don't often get email from [email protected]. Learn why this
is important<https://aka.ms/LearnAboutSenderIdentification>
EXTERNAL SENDER. Do not click links or open attachments unless you recognize
t: Friday, October 3, 2025 17:14
> To: [email protected]
> Subject: Weird behavior on Kafka Connect class loading
>
> You don't often get email from [email protected]. Learn why
> this is important<https://aka.ms/LearnAboutSenderIdentification>
>
&g
Mario Fiore Vitale created KAFKA-19758:
--
Summary: Weird behavior on Kafka Connect 4.1 class loading
Key: KAFKA-19758
URL: https://issues.apache.org/jira/browse/KAFKA-19758
Project: Kafka
gt; > I would like to start a vote on *KIP-1209: Add configuration to control
> > internal topic creation in Kafka Connect*
> >
> > KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
> > Discussion thread:
> > https://lists.apache.org/thread/l89rzzm0jd4ml7xx66mkxfztst281so7
> >
>
che.org At: 09/04/25 13:24:06 UTC-4:00To:
> >> [email protected]
> >> Subject: [VOTE] KIP-1209: Add configuration to control internal topic
> >> creation in Kafka Connect
> >>
> >> hi
> >>
> >> I would like to s
"$MAVEN_REPO/$GROUP_ID/$ARTIFACT_ID/$DEBEZIUM_VERSION/$ARTIFACT_ID-${DEBEZIUM_VERSION}${CLASSIFIER}.tar.gz"
> -o /tmp/debezium-openlineage-core-libs.tar.gz && \
> tar -xzvf /tmp/debezium-openlineage-core-libs.tar.gz -C
> /tmp/openlineage-libs --strip-components=1
>
&
rol+internal+topic+creation+in+Kafka+Connect
>
> On Mon, Sep 22, 2025 at 5:56 PM Chris Egerton
> wrote:
>
> > Hi Anton,
> >
> > Thanks, LGTM. Two small follow-up thoughts:
> >
> > 1) We could also consider changing the property name to
> > internal.topics
(non-binding)
>>
>> Thanks for the KIP
>>
>> From: [email protected] At: 09/04/25 13:24:06 UTC-4:00To:
>> [email protected]
>> Subject: [VOTE] KIP-1209: Add configuration to control internal topic
>> creation in Kafka Connect
>>
>> hi
>>
>
anks for the KIP!
>>
>> Yash
>>
>> On Thu, Sep 4, 2025 at 10:24 AM Anton Liauchuk
>> wrote:
>>
>> > hi
>> >
>> > I would like to start a vote on *KIP-1209: Add configuration to control
>> > internal topic creation
en that they're types that only exist in a particular DB, and there's no
(AFAICT) super-type that KC could infer them to be, I was thinking that a
potential solution might be to expose to users the ability to configure
other types that need casting in like these existing ones?
https:
Hi Anton,
I'm +1 (binding), thanks for the KIP!
Yash
On Thu, Sep 4, 2025 at 10:24 AM Anton Liauchuk wrote:
> hi
>
> I would like to start a vote on *KIP-1209: Add configuration to control
> internal topic creation in Kafka Connect*
>
> KIP: https://cwiki.apache.
Hi,
Thanks for the feedback. I’ve updated the KIP based on your comments,
please review
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect
On Mon, Sep 22, 2025 at 5:56 PM Chris Egerton
wrote:
> Hi An
25, 05:39 Anton Liauchuk wrote:
>
> > Hi,
> >
> > Thanks for the feedback. I’ve updated the KIP based on your comments,
> > please review
> >
> >
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creati
eter. Please review the new version:
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect#KIP1209:AddconfigurationtocontrolinternaltopiccreationinKafkaConnect-InternalTopicsManagementScript
>
> On Fri,
KIP-1209: Add configuration to control internal topic
> creation in Kafka Connect
>
> hi
>
> I would like to start a vote on *KIP-1209: Add configuration to control
> internal topic creation in Kafka Connect*
>
> KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
>
Hi,
Thanks for the suggestion! I’ve updated the KIP to use the worker config as
a command-line parameter. Please review the new version:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect#KIP1209
Anton Liauchuk wrote:
> Hi,
>
> I’ve added the CLI description to the proposal based on our discussion:
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+
Hi,
I’ve added the CLI description to the proposal based on our discussion:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect#KIP1209:AddconfigurationtocontrolinternaltopiccreationinKafkaConnect
total sense to have such a tool, which could be
especially useful before creating a new Kafka Connect cluster. Should I
update the KIP to include this proposed command-line tool?
On Fri, Sep 12, 2025 at 10:21 PM Chris Egerton wrote:
> Hi Anton,
>
> I agree that, while rare, the case you
+1 (non-binding)
On 2025/09/04 17:23:47 Anton Liauchuk wrote:
> hi
>
> I would like to start a vote on *KIP-1209: Add configuration to control
> internal topic creation in Kafka Connect*
>
> KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
> Discussion thread:
> https:/
68b85289d9214ae1dad88865d159b8e3658a4231544de36f429bd5R248
> > > > .
> > > >
> > > >
> > > > Please take a look at the KIP - it’s a really small configuration.
> > > >
> > > > Once we get the required number of votes, the PR can be merged.
&
configuration.
> > >
> > > Once we get the required number of votes, the PR can be merged.
> > >
> > > On Thu, Sep 4, 2025 at 9:49 PM Hector Geraldino (BLOOMBERG/ 919 3RD A)
> <
> > > [email protected]> wrote:
> > >
> > > &
rged.
> >
> > On Thu, Sep 4, 2025 at 9:49 PM Hector Geraldino (BLOOMBERG/ 919 3RD A) <
> > [email protected]> wrote:
> >
> > > +1 (non-binding)
> > >
> > > Thanks for the KIP
> > >
> > > From: [email protected] At: 09/04/
oomberg.net> wrote:
>
> > +1 (non-binding)
> >
> > Thanks for the KIP
> >
> > From: [email protected] At: 09/04/25 13:24:06 UTC-4:00To:
> > [email protected]
> > Subject: [VOTE] KIP-1209: Add configuration to control internal topic
> > creation
Hi,
+1 (non-binding)
Thanks for the KIP
Best regards,
Andrei Rudkouski
On 2025/09/04 17:23:47 Anton Liauchuk wrote:
> hi
>
> I would like to start a vote on *KIP-1209: Add configuration to control
> internal topic creation in Kafka Connect*
>
> KIP: https://cwiki.apach
+1 (non-binding)
Thanks for the KIP
From: [email protected] At: 09/04/25 13:24:06 UTC-4:00To:
[email protected]
Subject: [VOTE] KIP-1209: Add configuration to control internal topic creation
in Kafka Connect
hi
I would like to start a vote on *KIP-1209: Add configuration to control
hi
I would like to start a vote on *KIP-1209: Add configuration to control
internal topic creation in Kafka Connect*
KIP: https://cwiki.apache.org/confluence/x/GAq2Fg
Discussion thread:
https://lists.apache.org/thread/l89rzzm0jd4ml7xx66mkxfztst281so7
Thanks for your question.
The *auto.create.topics.enable* configuration will remain a broker-level
setting. The new proposed configuration,* internal.topics.creation*, will
be a Kafka Connect–level setting.
For Kafka Connect internal topics, there is a requirement that these topics
must have
is disabled, an exception is thrown when a
> > required topic does not exist. If the topic exists, there is an
> additional
> > validation to ensure that it has the correct cleanup policy.
> >
> > Please review the KIP
> >
> https://cwiki.apache.org/confluence/disp
e review the KIP
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect
> and PR. I’ll start the voting if there are no concerns
>
> On Tue, Aug 26, 2025 at 4:58 PM Anton Liauchuk wrote:
>
> > Hello everyon
it has the correct cleanup policy.
>
> Please review the KIP
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect
> and PR. I’ll start the voting if there are no concerns
>
> On Tue, Aug 26, 2
review the KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect
and PR. I’ll start the voting if there are no concerns
On Tue, Aug 26, 2025 at 4:58 PM Anton Liauchuk wrote:
> Hello everyone
>
> I'd lik
Hello everyone
I'd like to discuss a KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1209%3A+Add+configuration+to+control+internal+topic+creation+in+Kafka+Connect
small POC with discussion: https://github.com/apache/kafka/pull/20384
Motivation:
Kafka Connect requires several int
Shichao An created KAFKA-19633:
--
Summary: Kafka Connect connectors sent out zombie records during
rebalance
Key: KAFKA-19633
URL: https://issues.apache.org/jira/browse/KAFKA-19633
Project: Kafka
Hello everyone,
I’ve prepared a small POC to explore an option for disabling the automatic
creation of internal topics in Kafka Connect. The goal is to validate
whether this approach could help in scenarios where internal topics contain
information about many connectors, and accidental removal
Affects Versions: 4.1.0
>Reporter: Snehashis Pal
>Priority: Major
> Fix For: 4.1.0
>
>
> Add tests for plugin level isolation for Kafka connect (KIP-891).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
hi Kafka Community,
I would like to start a vote on KIP-1097.
KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1097%3A+Add+Kafka+Connect+exception+handler
Hi Kafka Community,
Since there haven't been any new comments on the DISCUSS thread recently,
I'd like to move KIP-1154 — *"Extending Support for Microsecond/Nanosecond
Precision for Kafka Connect
<https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=347933282>&qu
Hi all,
I'd like to raise a discussion around *[KAFKA-19070]*(
https://issues.apache.org/jira/browse/KAFKA-19070), which proposes a small
but impactful change to how Kafka Connect handles the `client.id`
configuration when set explicitly by the user.
*Problem*
Currently, if a user sets a c
/KAFKA/KIP-1097%3A+Add+Kafka+Connect+exception+handler
- POC branch: https://github.com/anton-liauchuk/kafka/pull/1/files
*What changed since the first draft*
1. *API* – new `*ErrorHandler*` interface with `*ErrorResponse {DROP, FAIL,
ACK}*` (inspired by
Hi All,
I'm building a custom Docker image for kafka Connect and planning to run it on
Kubernetes. I'm a bit stuck on whether I should use a Deployment or a
StatefulSet.
>From what I understand, the main difference that could affect Kafka Connect is
>the hostname/IP b
gt;
>>> Hi Chris,
>>> Can you please review this one too?
>>>
>>> On Sat, Apr 5, 2025 at 7:00 AM pritam kumar
>>> wrote:
>>>
>>>> Hi Kafka Community,
>>>> Sorry due to some changes I had to change the link to the
due to some changes I had to change the link to the kip.
>>> Here is the updated KIP link:
>>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
>>>
>>> On Sat, Apr 5, 2025 at 12:14 AM pri
;> Hi Kafka Community,
>> Sorry due to some changes I had to change the link to the kip.
>> Here is the updated KIP link:
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
>>
>> On Sat, Apr 5, 20
Snehashis Pal created KAFKA-19248:
-
Summary: Plugins Test for Multiversioning in Kafka Connect
Key: KAFKA-19248
URL: https://issues.apache.org/jira/browse/KAFKA-19248
Project: Kafka
Issue
3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
>
> On Sat, Apr 5, 2025 at 12:14 AM pritam kumar
> wrote:
>
>> Hi Kafka Community,
>>
>> I’d like to start a discussion on KIP-1153: Extending Support for
>> Microsecond Precision for Kafka Connect
>&
/ workers?
Many Thanks,
Jamie
On Wednesday 16 April 2025 at 10:57:01 BST, Jamie
<mailto:[email protected]> wrote:
Hi All,
I'm trying to implement a custom REST extension for Kafka Connect that allows a
token to be used for authentication.
When I have a single inst
om/apache/kafka/blob/e78e106221e7ce72af90b32fe6d6b3b454b1667b/connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java#L91
[2] -
https://cwiki.apache.org/confluence/display/KAFKA/KIP-507%3A+Securing+Internal+Connect+REST+Endpoints
Hope this helps,
Chris
On Tu
Hi All,
Has anyone managed to get a REST extension working with multiple connect
instances / workers?
Many Thanks,
Jamie
On Wednesday 16 April 2025 at 10:57:01 BST, Jamie
wrote:
Hi All,
I'm trying to implement a custom REST extension for Kafka Connect that allows a
token
> > > > >
> > > > > Thanks
> > > > > Sudesh
> > > > >
> > > > > On 2025/04/05 01:30:49 pritam kumar wrote:
> > > > > > Hi Kafka Community,
> > > > > > Sorry due to some
t; Hi Pritam ! Thanks for the KIP !
> > > > > > Let’s extend the KIP to also add support for Nanosecond
> precision!
> > > > > >
> > > > > > Thanks
> > > > > > Sudesh
> > > > > >
> > > > >
Nanosecond precision!
>>>
>>> Thanks
>>> Sudesh
>>>
>>> On 2025/04/05 01:30:49 pritam kumar wrote:
>>> > Hi Kafka Community,
>>> > Sorry due to some changes I had to change the link to the kip.
>>> > Here is the updated KIP
>>> Thanks
>>>> Sudesh
>>>>
>>>> On 2025/04/05 01:30:49 pritam kumar wrote:
>>>> > Hi Kafka Community,
>>>> > Sorry due to some changes I had to change the link to the kip.
>>>> > Here is the updated KIP link:
>&g
Sudesh
>>
>> On 2025/04/05 01:30:49 pritam kumar wrote:
>> > Hi Kafka Community,
>> > Sorry due to some changes I had to change the link to the kip.
>> > Here is the updated KIP link:
>> >
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-115
://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
> >
> > On Sat, Apr 5, 2025 at 12:14 AM pritam kumar
> > wrote:
> >
> > > Hi Kafka Community,
> > >
> > > I’d like to
:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
>
> On Sat, Apr 5, 2025 at 12:14 AM pritam kumar
> wrote:
>
> > Hi Kafka Community,
> >
> > I’d like to start a discussion on KIP-1153: Extending Suppo
Hi All,
I'm trying to implement a custom REST extension for Kafka Connect that allows a
token to be used for authentication.
When I have a single instance of Kafka connect running in distributed mode
(i.e. 1 worker) this works as expected. However, when I add another instance
(another w
Hi Kafka Community,
Sorry due to some changes I had to change the link to the kip.
Here is the updated KIP link:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1154%3A+Extending+support+for+Microsecond+Precision+for+Kafka+Connect
On Sat, Apr 5, 2025 at 12:14 AM pritam kumar
wrote:
>
Hi Kafka Community,
I’d like to start a discussion on KIP-1153: Extending Support for
Microsecond Precision for Kafka Connect
<https://cwiki.apache.org/confluence/display/KAFKA/KIP-1153%3A+Extending+Support+for+Microsecond+Precision+for+Kafka+Connect>
.
The primary motivation behind this
Pritam Kumar created KAFKA-19086:
Summary: Extending support for Microsecond Precision for Kafka
Connect
Key: KAFKA-19086
URL: https://issues.apache.org/jira/browse/KAFKA-19086
Project: Kafka
out.
>
> Thanks,
> Greg
>
> [1]
>
> https://github.com/confluentinc/schema-registry/blob/e461e9659ef1532a95b3f2dfd38e843d766aa955/schema-converter/src/main/java/io/confluent/connect/schema/ConnectEnum.java
> [2]
>
> https://github.com/confluentinc/schema-registry/blob/
[
https://issues.apache.org/jira/browse/KAFKA-16326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-16326.
-
Resolution: Fixed
> Kafka Connect unable to find javax dependency on Quarkus update to
schema-converter/src/main/java/io/confluent/connect/schema/ConnectEnum.java
[2]
https://github.com/confluentinc/schema-registry/blob/e461e9659ef1532a95b3f2dfd38e843d766aa955/schema-converter/src/main/java/io/confluent/connect/schema/ConnectUnion.java
[3] https://github.com/confluentinc/kafka-connect-
Hi Mario,
Thanks for the KIP.
My view is that it would be nice for Kafka to have a data model so that
Kafka could do natively the things that people use schema registries
for today. I'm not convinced that the Kafka Connect data classes are
really up to the job, so I'm not sure that the
omberg.net> ha scritto:
>> > >
>> > > > Hey Mario,
>> > > >
>> > > > From a quick read of this KIP, it's not super clear to me what
>> problem
>> > it
>> > > > is trying to solve. The motivation states that &
[
https://issues.apache.org/jira/browse/KAFKA-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield resolved KAFKA-7776.
-
Resolution: Fixed
> Kafka Connect values converter parsing of ISO8601 not work
I'm not sure what you mean
> by
> > > > that.
> > > >
> > > > Can you maybe add one or two examples of things that are not possible
> > to
> > > > do today and could be achieved by this refactor. If this proposal is
> &
not sure what you mean by
> > > that.
> > >
> > > Can you maybe add one or two examples of things that are not possible
> to
> > > do today and could be achieved by this refactor. If this proposal is
> more
> > > about improving the ergonomics of us
refactor. If this proposal is more
> > about improving the ergonomics of users of these classes, that's also
> > valuable IMO.
> >
> > From: [email protected] At: 12/18/24 08:32:28 UTC-5:00To:
> > [email protected]
> > Subject: [DISCUSS] KIP-1122:
his proposal is more
> about improving the ergonomics of users of these classes, that's also
> valuable IMO.
>
> From: [email protected] At: 12/18/24 08:32:28 UTC-5:00To:
> [email protected]
> Subject: [DISCUSS] KIP-1122: Create a dedicated data module for Kafka
> Conn
SCUSS] KIP-1122: Create a dedicated data module for Kafka Connect
data classes
Hi Everyone,
I would like to start a discussion on KIP-1122: Create a dedicated data
module for Kafka Connect data classes [1].
[1]
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1122%3A+Create+a+dedicated
+data
Hi Everyone,
I would like to start a discussion on KIP-1122: Create a dedicated data
module for Kafka Connect data classes [1].
[1]
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1122%3A+Create+a+dedicated+data+module+for+Kafka+Connect+data+classes
Regards,
--
Mario Fiore Vitale
Mario Fiore Vitale created KAFKA-18299:
--
Summary: Promote Kafka Connect data package as a dedicated module
Key: KAFKA-18299
URL: https://issues.apache.org/jira/browse/KAFKA-18299
Project: Kafka
Tom Thornton created KAFKA-18073:
Summary: Data loss when Kafka Connect retriable exception raised
Key: KAFKA-18073
URL: https://issues.apache.org/jira/browse/KAFKA-18073
Project: Kafka
Basapuram Kumar created KAFKA-17982:
---
Summary: Kafka Connect: Configurable JMX Port for Metrics
Collection
Key: KAFKA-17982
URL: https://issues.apache.org/jira/browse/KAFKA-17982
Project: Kafka
Hector Geraldino created KAFKA-17958:
Summary: Publish metrics for skipped records in Kafka Connect
Key: KAFKA-17958
URL: https://issues.apache.org/jira/browse/KAFKA-17958
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kevin Wu resolved KAFKA-17916.
--
Resolution: Fixed
> Convert Kafka Connect system tests to use KR
Kevin Wu created KAFKA-17916:
Summary: Convert Kafka Connect system tests to use KRaft
Key: KAFKA-17916
URL: https://issues.apache.org/jira/browse/KAFKA-17916
Project: Kafka
Issue Type
Ajit Singh created KAFKA-17424:
--
Summary: Memory optimisation for Kafka-connect
Key: KAFKA-17424
URL: https://issues.apache.org/jira/browse/KAFKA-17424
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-12818.
-
Resolution: Duplicate
> Memory leakage when kafka connect 2.7 uses directory config provi
Hi,
I've not received a reply from Gunnar since last month, so I'll pick
this KIP up.
Thanks,
Mickael
On Tue, Jun 18, 2024 at 6:01 PM Mickael Maison wrote:
>
> Hi Gunnar,
>
> I think this KIP would be a great addition to Kafka Connect but it
> looks like it'
gt; > Regards,
> > - Adrian
> >
> > From: Edoardo Comar
> > Date: Sunday, 16 June 2024 at 07:57
> > To: [email protected]
> > Subject: [EXTERNAL] Re: [VOTE] KIP-1017: A health check endpoint for
> Kafka Connect
> > Thanks for this KIP, Chris,
&
Hi Gunnar,
I think this KIP would be a great addition to Kafka Connect but it
looks like it's been abandoned.
Are you still interested in working on this? If you need some time or
help, that's fine, just let us know.
If not, no worries, I'm happy to pick it up if needed.
Thanks,
supported
by the Apache Kafka project. If/when an issue with the Connect framework is
implicated, a new ticket may be opened with details about that issue.
> ssue when kafka connect worker pod restart, during creation of nested
> partition directories in hdfs file
t: [EXTERNAL] Re: [VOTE] KIP-1017: A health check endpoint for Kafka
> Connect
> Thanks for this KIP, Chris,
>
> +1 (binding)
>
> Edo
>
> On Fri, 14 Jun 2024 at 20:20, Greg Harris
> wrote:
> >
> > Hey Chris,
> >
> > Thanks for the KIP.
> >
> &
Hi Chris,
+1 (non-binding)
Regards,
- Adrian
From: Edoardo Comar
Date: Sunday, 16 June 2024 at 07:57
To: [email protected]
Subject: [EXTERNAL] Re: [VOTE] KIP-1017: A health check endpoint for Kafka
Connect
Thanks for this KIP, Chris,
+1 (binding)
Edo
On Fri, 14 Jun 2024 at 20:20, Greg
4 at 8:44 AM Hector Geraldino (BLOOMBERG/ 919 3RD A) <
> [email protected]> wrote:
>
> > Thanks Chris,
> >
> > +1 (non-binding)
> >
> > From: [email protected] At: 06/14/24 11:43:02 UTC-4:00To:
> > [email protected]
> > Subj
t; > > itself as a log about the workers' behavior. I understand if you
> think
> > > > it's
> > > > > such a scope change that it should be an improvement KIP, but would
> > > like
> > > > to
> > > > > gauge wha
At: 06/14/24 11:43:02 UTC-4:00To:
> [email protected]
> Subject: Re: [VOTE] KIP-1017: A health check endpoint for Kafka Connect
>
> Hi Chris,
>
> +1 (binding)
>
> Thanks,
> Mickael
>
> On Fri, Jun 14, 2024 at 5:01 PM Andrew Schofield
> wrote:
> >
scope change that it should be an improvement KIP, but would
> > like
> > > to
> > > > gauge what you think about this.
> > > >
> > > > Regards,
> > > > Viktor
> > > >
> > > > On Tue, Jun 11, 2024 at 4:34 PM Chris Eg
Thanks Chris,
+1 (non-binding)
From: [email protected] At: 06/14/24 11:43:02 UTC-4:00To:
[email protected]
Subject: Re: [VOTE] KIP-1017: A health check endpoint for Kafka Connect
Hi Chris,
+1 (binding)
Thanks,
Mickael
On Fri, Jun 14, 2024 at 5:01 PM Andrew Schofield
wrote:
>
&
>
> > Happy Friday! I'd like to kick off a vote on KIP-1017.
> >
> > Design doc:
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1017%3A+Health+check+endpoint+for+Kafka+Connect
> >
> > Discussion thread:
> > https://lists.apache.org/thread/95nto84wtogdgk3v97rxcwxr258wnjnt
> >
> > Cheers,
> >
> > Chris
>
Hi Chris,
Thanks for the KIP.
+1 (non-binding)
Thanks,
Andrew
> On 14 Jun 2024, at 15:48, Chris Egerton wrote:
>
> Hi all,
>
> Happy Friday! I'd like to kick off a vote on KIP-1017.
>
> Design doc:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1017%3A+He
Hi all,
Happy Friday! I'd like to kick off a vote on KIP-1017.
Design doc:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1017%3A+Health+check+endpoint+for+Kafka+Connect
Discussion thread:
https://lists.apache.org/thread/95nto84wtogdgk3v97rxcwxr258wnjnt
Cheers,
Chris
1 - 100 of 1085 matches
Mail list logo
