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:jamied...@aol.co.uk> 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: dev@kafka.apache.org At: 12/18/24 08:32:28 UTC-5:00To:
> > dev@kafka.apache.org
> > Subject: [DISCUSS] KIP-1122:
his proposal is more
> about improving the ergonomics of users of these classes, that's also
> valuable IMO.
>
> From: dev@kafka.apache.org At: 12/18/24 08:32:28 UTC-5:00To:
> dev@kafka.apache.org
> 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: dev@kafka.apache.org
> > 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: dev@kafka.apache.org
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) <
> hgerald...@bloomberg.net> wrote:
>
> > Thanks Chris,
> >
> > +1 (non-binding)
> >
> > From: dev@kafka.apache.org At: 06/14/24 11:43:02 UTC-4:00To:
> > dev@kafka.apache.org
> > 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:
> dev@kafka.apache.org
> 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: dev@kafka.apache.org At: 06/14/24 11:43:02 UTC-4:00To:
dev@kafka.apache.org
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
ed. I don't plan on
> > > adding any structured data such as error codes or something like a
> > "phase"
> > > field with values like READING_CONFIG_TOPIC quite yet, but there is
> room
> > > for us to add human-readable information on t
t; Thanks for your comments/questions! The responses to them are related
> > so
> > > > I'll try to address both at once.
> > > >
> > > > The most recent update I made to the KIP should help provide insight
> > into
> > > > what's
room
> > for us to add human-readable information on the causes of failure in the
> > "message" field (see KAFKA-15563 [1] and its PR [2] for an example of
> what
> > kind of information we might provide to users). Part of the problem is
> that
> > while
ation on the causes of failure in the
> "message" field (see KAFKA-15563 [1] and its PR [2] for an example of what
> kind of information we might provide to users). Part of the problem is that
> while I've heard plenty of (justified!) complaints about the Kafka Connect
robust implementation before
considering further enhancements.
Cheers,
- Adrian.
From: Chris Egerton
Date: Tuesday, 11 June 2024 at 15:34
To: dev@kafka.apache.org
Subject: [EXTERNAL] Re: [DISCUSS] KIP-1017: A health check endpoint for Kafka
Connect
Hi Adrian,
Thanks for your comments/questions
ind of information we might provide to users). Part of the problem is that
while I've heard plenty of (justified!) complaints about the Kafka Connect
REST API becoming unavailable and the difficulties users face with
debugging their workers when that happens, I still don't feel we have a
) transition more of the conditions over to being handled by
automation.
Regards,
- Adrian
From: Chris Egerton
Date: Monday, 10 June 2024 at 15:26
To: dev@kafka.apache.org
Subject: [EXTERNAL] Re: [DISCUSS] KIP-1017: A health check endpoint for Kafka
Connect
Hi all,
Thanks for the positive feedback
e KIP looks good to me. +1
> >
> > Thanks,
> > Mickael
> >
> > On Fri, Jan 26, 2024 at 8:41 PM Chris Egerton
> wrote:
> >>
> >> Hi all,
> >>
> >> Happy Friday! I'd like to kick off discussion for KIP-1017, which (as
> the
>
KIP looks good to me. +1
>
> Thanks,
> Mickael
>
> On Fri, Jan 26, 2024 at 8:41 PM Chris Egerton wrote:
>>
>> Hi all,
>>
>> Happy Friday! I'd like to kick off discussion for KIP-1017, which (as the
>> title suggests) proposes adding a health check e
Hi Chris,
Happy Friday! The KIP looks good to me. +1
Thanks,
Mickael
On Fri, Jan 26, 2024 at 8:41 PM Chris Egerton wrote:
>
> Hi all,
>
> Happy Friday! I'd like to kick off discussion for KIP-1017, which (as the
> title suggests) proposes adding a health check endpoi
[
https://issues.apache.org/jira/browse/KAFKA-16838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-16838.
---
Fix Version/s: 3.9.0
Resolution: Fixed
> Kafka Connect loads old tasks from remo
[
https://issues.apache.org/jira/browse/KAFKA-16837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-16837.
---
Fix Version/s: 3.9.0
Resolution: Fixed
> Kafka Connect fails on update connector
[
https://issues.apache.org/jira/browse/KAFKA-5451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris resolved KAFKA-5451.
Resolution: Won't Do
Kafka Connect needs the results of plugin scanning to answer basic
=service_load on 3.6+, see
KAFKA-14627/KIP-898 for more details.
> Reduce startup time for Kafka Connect workers
> -
>
> Key: KAFKA-6208
> URL: https://issues.apache.org/jira/browse/KAFKA-6208
>
Sergey Ivanov created KAFKA-16838:
-
Summary: Kafka Connect loads old tasks from removed connectors
Key: KAFKA-16838
URL: https://issues.apache.org/jira/browse/KAFKA-16838
Project: Kafka
Sergey Ivanov created KAFKA-16837:
-
Summary: Kafka Connect fails on update connector for incorrect
previous Config Provider tasks
Key: KAFKA-16837
URL: https://issues.apache.org/jira/browse/KAFKA-16837
[
https://issues.apache.org/jira/browse/KAFKA-16603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-16603.
---
Resolution: Not A Bug
> Data loss when kafka connect sending data to Ka
Anil Dasari created KAFKA-16603:
---
Summary: Data loss when kafka connect sending data to Kafka
Key: KAFKA-16603
URL: https://issues.apache.org/jira/browse/KAFKA-16603
Project: Kafka
Issue Type
Pau Ortega Puig created KAFKA-16326:
---
Summary: Kafka Connect unable to find javax dependency on Quarkus
update to 3.X
Key: KAFKA-16326
URL: https://issues.apache.org/jira/browse/KAFKA-16326
Project
what
seems like a simple and necessary patch.
Is the SslEngineFactory refactoring requirement blocking?
[1].
https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
[2]. https://lists.apache.org/thread/wc4v5v3pynl15g1q547m2croqsqgmzpw
https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
[2]. https://lists.apache.org/thread/wc4v5v3pynl15g1q547m2croqsqgmzpw
--
With best regards,
Taras Ledkov
Hi all,
Happy Friday! I'd like to kick off discussion for KIP-1017, which (as the
title suggests) proposes adding a health check endpoint for Kafka Connect:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1017%3A+Health+check+endpoint+for+Kafka+Connect
This is one of the longest-sta
> > Thanks for the KIP! I think the aggressive default and deprecation
> > > > > schedule is the right choice for this change.
> > > > >
> > > > > +1 (binding)
> > > > >
> > > > > On Wed, Jan 3, 2024 at 9:01 AM Mickael
d, Jan 3, 2024 at 9:01 AM Mickael Maison <
> > mickael.mai...@gmail.com>
> > > > wrote:
> > > > >
> > > > > Hi Chris,
> > > > >
> > > > > +1 (binding), thanks for the KIP
> > > > >
> > > > >
; > Mickael
> > > >
> > > > On Tue, Jan 2, 2024 at 8:55 PM Hector Geraldino (BLOOMBERG/ 919 3RD
> A)
> > > > wrote:
> > > > >
> > > > > +1 (non-binding)
> > > > >
> > > > > Th
nding), thanks for the KIP
> > >
> > > Mickael
> > >
> > > On Tue, Jan 2, 2024 at 8:55 PM Hector Geraldino (BLOOMBERG/ 919 3RD A)
> > > wrote:
> > > >
> > > > +1 (non-binding)
> > > >
> > > > Thanks Chris!
>
+1 (binding), thanks for the KIP
> >
> > Mickael
> >
> > On Tue, Jan 2, 2024 at 8:55 PM Hector Geraldino (BLOOMBERG/ 919 3RD A)
> > wrote:
> > >
> > > +1 (non-binding)
> > >
> > > Thanks Chris!
> > >
> > > From: dev@
, 2024 at 8:55 PM Hector Geraldino (BLOOMBERG/ 919 3RD A)
> wrote:
> >
> > +1 (non-binding)
> >
> > Thanks Chris!
> >
> > From: dev@kafka.apache.org At: 01/02/24 11:49:18 UTC-5:00To:
> > dev@kafka.apache.org
> > Subject: Re: [VOTE] KIP-1004: En
ect: Re: [VOTE] KIP-1004: Enforce tasks.max property in Kafka Connect
>
> Hi all,
>
> Happy New Year! Wanted to give this a bump now that the holidays are over
> for a lot of us. Looking forward to people's thoughts!
>
> Cheers,
>
> Chris
>
> On Mon, Dec 4, 2023 at 10
+1 (non-binding)
Thanks Chris!
From: dev@kafka.apache.org At: 01/02/24 11:49:18 UTC-5:00To:
dev@kafka.apache.org
Subject: Re: [VOTE] KIP-1004: Enforce tasks.max property in Kafka Connect
Hi all,
Happy New Year! Wanted to give this a bump now that the holidays are over
for a lot of us
enforcement for the
> tasks.max connector property in Kafka Connect.
>
> The KIP:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1004%3A+Enforce+tasks.max+property+in+Kafka+Connect
>
> The discussion thread:
> https://lists.apache.org/thread/scx75cjwm19jyt19wxky41q9smf5nx6d
>
> Cheers,
>
> Chris
>
Hi team,
Ping for review / vote for KIP-967 [1].
Voting thread is here [2]
[1].
https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
[2]. https://lists.apache.org/thread/wc4v5v3pynl15g1q547m2croqsqgmzpw
--
With best regards
entally introduced a breaking change for Kafka
Connect in https://github.com/apache/kafka/pull/9669. Before that change,
the SourceTask::stop method [1] would be invoked on a separate thread from
the one that did the actual data processing for the task (polling the task
for records, transforming
Chris Egerton created KAFKA-15988:
-
Summary: Kafka Connect OffsetsApiIntegrationTest takes too long
Key: KAFKA-15988
URL: https://issues.apache.org/jira/browse/KAFKA-15988
Project: Kafka
are being passed to their factory. Instead, the default SSL
> > engine factory used by Connect can perform this logic, and we can let other
> > custom factories be responsible for their own default values.
> >
> >
> > Cheers,
> >
> > Chris
> >
> &
ed, Nov 29, 2023 at 8:36 AM Taras Ledkov wrote:
>
> > Hi team,
> >
> > Ping for review / vote for KIP-967 [1].
> > Voting thread is here [2]
> >
> > [1].
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+f
gt; Hi team,
> >
> > Ping for review / vote for KIP-967 [1].
> > Voting thread is here [2]
> >
> > [1].
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
> > [2]. https://github.com/apache/kafka/pull/14203
> > [2]. https://lists.apache.org/thread/wc4v5v3pynl15g1q547m2croqsqgmzpw
> >
> > --
> > With best regards,
> > Taras Ledkov
> >
, Nov 29, 2023 at 8:36 AM Taras Ledkov wrote:
> Hi team,
>
> Ping for review / vote for KIP-967 [1].
> Voting thread is here [2]
>
> [1].
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
> [2]
e Public Interfaces
> > > > section states:
> > > >
> > > > "If the connector generated excessive tasks after being reconfigured,
> > > then
> > > > any existing tasks for the connector will be allowed to continue
> > runn
Hi all,
I'd like to call for a vote on KIP-1004, which adds enforcement for the
tasks.max connector property in Kafka Connect.
The KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1004%3A+Enforce+tasks.max+property+in+Kafka+Connect
The discussion thread:
https://lists.apach
Hi team,
Ping for review / vote for KIP-967 [1].
Voting thread is here [2]
[1].
https://cwiki.apache.org/confluence/display/KAFKA/KIP-967%3A+Support+custom+SSL+configuration+for+Kafka+Connect+RestServer
[2]. https://github.com/apache/kafka/pull/14203
[2]. https://lists.apache.org/thread
ed to continue
> running,
> > > unless that existing set of tasks also exceeds the tasks.max property."
> > >
> > > Would not failing the connector land us in the second scenario of
> > > 'Rejected Alternatives'?
> > >
> > > From
asks for the connector will be allowed to continue running,
> > unless that existing set of tasks also exceeds the tasks.max property."
> >
> > Would not failing the connector land us in the second scenario of
> > 'Rejected Alternatives'?
> >
> > Fr
ev@kafka.apache.org
> Subject: [DISCUSS] KIP-1004: Enforce tasks.max property in Kafka Connect
>
> Hi all,
>
> I'd like to open up KIP-1004 for discussion:
>
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1004%3A+Enforce+tasks.max+
> property+in+Kafka+Connect
>
&g
S] KIP-1004: Enforce tasks.max property in Kafka Connect
Hi all,
I'd like to open up KIP-1004 for discussion:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1004%3A+Enforce+tasks.max+
property+in+Kafka+Connect
As a brief summary: this KIP proposes that the Kafka Connect runtime start
failing c
Henrique Mota created KAFKA-15841:
-
Summary: Add Support for Topic-Level Partitioning in Kafka Connect
Key: KAFKA-15841
URL: https://issues.apache.org/jira/browse/KAFKA-15841
Project: Kafka
Hi all,
I'd like to open up KIP-1004 for discussion:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1004%3A+Enforce+tasks.max+property+in+Kafka+Connect
As a brief summary: this KIP proposes that the Kafka Connect runtime start
failing connectors that generate a greater number of
1 - 100 of 1038 matches
Mail list logo
