[
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
y? Let me know what you think.
All I can think of is:
- BaseSslEngineFactory;
- StaticSslEngineFactory;
- NonReconfigurableSslEngineFactory.
But I'm afraid that it would be hard to find sponsors to review this.
My proposal: restrict the scope of this KIP to Kafka Connect config
actory may want to
use property names that aren't available out-of-the-box with Kafka Connect
(i.e., which aren't defined in the DistributedConfig [5] or
StandaloneConfig [6] class).
It also sounds like (reading the KIP again) we're proposing that SSL engine
factory classes only be c
ies are
not prefixed with "listeners.https.".
I guess that the definitions of SSL properties at the root of the
`WorkerConfig` is unclean / buggy / may lead to unexpected behavior.
So, I would like to fix / improve this test.
> 5. There are several methods in the SslEngineFactory interfa
ests that are already covered by the existing code
base, but if that's the case, it'd be nice to see this clarified as the
assumption is usually that items in the test plan cover changes that will
have to be implemented for the KIP.
5. There are several methods in the Ssl
II'd like to call a vote on KIP-967: Support custom SSL configuration for
>> Kafka Connect RestServer [1].
>> Discussion thread [2] was started more then 2 month ago and there was not
>> any negative or critical comments.
>>
>> [1].
>> https://cwik
nding)
Thanks,
Greg
On Fri, Oct 20, 2023 at 8:03 AM Taras Ledkov wrote:
>
> Hi Kafka Team.
>
> II'd like to call a vote on KIP-967: Support custom SSL configuration for
> Kafka Connect RestServer [1].
> Discussion thread [2] was started more then 2 month ago and ther
Hi Kafka Team.
II'd like to call a vote on KIP-967: Support custom SSL configuration for Kafka
Connect RestServer [1].
Discussion thread [2] was started more then 2 month ago and there was not any
negative or critical comments.
[1].
https://cwiki.apache.org/confluence/display/KAFKA/KIP-9
Hi Ashwin,
> I was referring to (and did not understand) the removal of L141 in
> clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java
This line is moved to "new" private method `instantiateSslEngineFactory0 `.
Please take a look at the `SslFactory:L132` at the patch.
Just
as well
>
> De: dev@kafka.apache.org A: 10/09/23 05:16:06 UTC-4:00A:
> dev@kafka.apache.org
> Subject: Re: [VOTE] KIP-976: Cluster-wide dynamic log adjustment for Kafka
> Connect
>
> Hi Chris,
>
> +1 (non binding)
>
> Thanks
> Fede
>
> On Sun, Oct 8, 2023 at
Hello Taras,
> Do you think that something needs to be corrected in KIP to make it more
understandable without PR? Do you have any advice?
Ha - no. I just wanted to thank you for sharing the PR which helped me as a
newbie.
> If I understood the question correctly:
I was referring to (and did not
Good stuff, +1 (non-binding) from me as well
De: dev@kafka.apache.org A: 10/09/23 05:16:06 UTC-4:00A: dev@kafka.apache.org
Subject: Re: [VOTE] KIP-976: Cluster-wide dynamic log adjustment for Kafka
Connect
Hi Chris,
+1 (non binding)
Thanks
Fede
On Sun, Oct 8, 2023 at 10:11 AM Yash Mayya
Hi Chris,
+1 (non-binding)
Finally, there is no need to use external intrusion tools to change the log
level of kafka connect online! Thanks for the KIP!
best,
hudeqi
2023 at 9:05 AM Chris Egerton
> > > wrote:
> > > >
> > > > Hi all,
> > > >
> > > > I'd like to call for a vote on KIP-976, which augments the existing
> > > dynamic
> > > > logger adjustment REST API for
Hi, Kafka team.
1. Ping to review KIP.
2. I dare say that the low activity in the discussion of KIP-967 means that
KIP-967 is ready for voting?
--
With best regards
Taras Ledkov
gt; >
> > On Fri, Oct 6, 2023 at 9:05 AM Chris Egerton
> > wrote:
> > >
> > > Hi all,
> > >
> > > I'd like to call for a vote on KIP-976, which augments the existing
> > dynamic
> > > logger adjustment REST API for Kafka Connect
Authorization =
headers.getHeaderString(HttpHeaders.AUTHORIZATION);
if (credentialAuthorization != null) {
req.header(HttpHeaders.AUTHORIZATION, credentialAuthorization);
}
}
}
This is of course risky and it would be significantly more convenient if this
functi
> broadcast is better than REST forwarding.
>
> +1 (binding)
>
> Thanks,
> Greg
>
> On Fri, Oct 6, 2023 at 9:05 AM Chris Egerton
> wrote:
> >
> > Hi all,
> >
> > I'd like to call for a vote on KIP-976, which augments the existing
> dynamic
&
Hi Yeikel,
Neat question! And thanks for the link to the RestClient code; very helpful.
I don't believe there's a way to configure Kafka Connect to add these
headers to forwarded requests right now. You may be able to do some kind of
out-of-band proxy magic to intercept forwarded re
:
>
> Hi all,
>
> I'd like to call for a vote on KIP-976, which augments the existing dynamic
> logger adjustment REST API for Kafka Connect to apply changes cluster-wide
> instead on a per-worker basis.
>
> The KIP:
> https://cwiki.apache.org/confluence/display/KAFKA/K
Hi all,
I'd like to call for a vote on KIP-976, which augments the existing dynamic
logger adjustment REST API for Kafka Connect to apply changes cluster-wide
instead on a per-worker basis.
The KIP:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-976:+Cluster-wide+dynamic+log+adjus
1 - 100 of 1018 matches
Mail list logo
