multiple TLS listeners

Hi,    I'm new to Java-SSL and Kafka. Is it possible to configure multiple SSL listeners (say, one for inter-cluster, the other one for intra-cluster communication)? How does Kafka pick up a appropriate certificate for incoming request. Thanks! Shuxin

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1334

See Changes: -- [...truncated 511193 lines...] [2022-11-03T19:48:01.838Z] > Task :clients:publishMavenJavaPublicationToMavenLocal [2022-11-03T19:48:01.838Z] > Task

[DISCUSS] KIP-883: Add delete callback method to Connector API

Hi everyone, I've submitted KIP-883, which introduces a callback to the public Connector API called when deleting a connector: https://cwiki.apache.org/confluence/display/KAFKA/KIP-883%3A+Add+delete+callback+method+to+Connector+API It adds a new `deleted()` method (open to better naming

[jira] [Created] (KAFKA-14354) Add delete callback method to Connector API

Hector Geraldino created KAFKA-14354: Summary: Add delete callback method to Connector API Key: KAFKA-14354 URL: https://issues.apache.org/jira/browse/KAFKA-14354 Project: Kafka Issue

[jira] [Resolved] (KAFKA-13434) Add a public API for AbstractCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-13434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hector Geraldino resolved KAFKA-13434. -- Resolution: Won't Do KIP has been discarded > Add a public API for

Re: [DISCUSS] KIP-882: Make Kafka Connect REST API request timeouts configurable

Hey Yash, Thanks for the KIP! This looks like a useful feature. I think the discussion thread already has some great points by Chris. Just a couple of points/clarifications=> Regarding, pt#2 , I guess it might be better to forward to the leader as suggested by Yash. Having said that, why does

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Hi, David, Thanks for the reply. 20/21 Yes, but separate listeners are optional. It's possible for the nodes to use a single port for both client and server side communications. Thanks, Jun On Thu, Nov 3, 2022 at 9:59 AM David Arthur wrote: > 20/21, in combined mode we still have a separate

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

20/21, in combined mode we still have a separate listener for the controller APIs, e.g., listeners=PLAINTEXT://:9092,CONTROLLER://:9093 inter.broker.listener.name=PLAINTEXT controller.listener.names=CONTROLLER advertised.listeners=PLAINTEXT://localhost:9092 Clients still talk to the broker

Re: [DISCUSS] KIP-881: Rack-aware Partition Assignment for Kafka Consumers

Hi Rajini, If I understand correctly, the client.rack config would stay supported after KIP-848 but does it expand the scope of that KIP too with this config? I mean that currently you propose ConsumerProtocolSubscription to be used but this protocol won't be available and we need to transfer the

[jira] [Resolved] (KAFKA-14058) Replace EasyMock and PowerMock with Mockito in ExactlyOnceWorkerSourceTaskTest

[ https://issues.apache.org/jira/browse/KAFKA-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14058. --- Fix Version/s: 3.4.0 Resolution: Fixed > Replace EasyMock and PowerMock with Mockito

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Hi, David, Thanks for the reply. 20/21. When KRaft runs in the combined mode, does a controller know whether an ApiRequest is from a client or another broker? 40. Adding a "None" state sounds reasonable. Thanks, Jun On Thu, Nov 3, 2022 at 8:39 AM David Arthur wrote: > Jun, > > 20/21 If we

Re: [DISCUSS] KIP-866 ZooKeeper to KRaft Migration

Jun, 20/21 If we use a tagged field, then I don't think clients need to be concerned with it, right?. In ApiVersionsResponse sent by brokers to clients, this field would be omitted. Clients can't connect directly to the KRaft controller nodes. Also, we have a precedent of sending controller node

Re: [DISCUSS] KIP-882: Make Kafka Connect REST API request timeouts configurable

Hi Yash, RE 2: That's a great point about validations already being performed by the leader. For completeness's sake, I'd like to note that this only holds for valid configurations; invalid ones are caught right now before being forwarded to the leader. Still, I think it's fine to forward to the

[GitHub] [kafka-site] cadonna merged pull request #460: Add PMC member role to Bruno

cadonna merged PR #460: URL: https://github.com/apache/kafka-site/pull/460 -- 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:

[GitHub] [kafka-site] cadonna commented on pull request #460: Add PMC member role to Bruno

cadonna commented on PR #460: URL: https://github.com/apache/kafka-site/pull/460#issuecomment-1301727479 The change renders as follows: https://user-images.githubusercontent.com/1042170/199666188-a123b334-1a36-4355-8a6d-505064e27ba4.png;> -- This is an automated message from

Re: [ANNOUNCE] New Kafka PMC Member: Bruno Cadonna

Thank you all! I am really honoured to have become a PMC member. Looking forward to contributing further to Apache Kafka. Best, Bruno On 02.11.22 17:02, Levani Kokhreidze wrote: Congrats Bruno, well deserved! On Wed, 2 Nov 2022, 11:11 Jorge Esteban Quilcate Otoya, <