![]() Load your jar containing the io.圜ustomLoginCallbackHandler class in Conduktor plugins.Configure your cluster with an additional property: .class=io.圜ustomLoginCallbackHandler.(MessagePack, etc.)įor example, if you're using OAuth2 to authenticate the connections to your Kafka cluster, to allow Conduktor to connect to your cluster, you'll need to: Deserializing your topics messages with a custom Kafka deserializer.Authentication of Conduktor requests to your Kafka cluster(s) if you're using an authentication mechanism not natively supported by Kafka.These customs jars are useful to extend the capabilities of our internal Kakfa clients. The Plugins configuration allows you to load your custom jars into Conduktor.\ Please provide the port, user, authentication method (password or SSH key pair) and test the SSH configuration. The SSH configuration enables Conduktor to directly access your brokers machines, enabling features like the rolling restart feature. Average Kafka users should not need to fill up the details of that tab. The SSH configuration is quite powerful and should only be allowed to be set-up for your KafkaĪdministrators. How to Connect to a secured Schema Registry? Īdd this in the additional properties (notice the schema.registry. Additional Properties: any key value pair needed to make the connection workĪfter entering the necessary details, you can test the connectivity to your schema registry.Security: Choose the security type (None, Basic Auth, Bearer Token).URL: HTTP or HTTPS endpoint of your schema registry.These detail are necessary to activate the "Schema Registry" tab in Conduktor, as well as consume and produce data in Avro format. ![]() In case you are using the Confluent Schema Registry and usually Avro data, you should use this tab to setup the connection details to your registry. If you are using the SASL/OAUTHBEARER authentication with a custom token endpoint, do not forget to change the token endpoint URL.Ĭlick on create to go back to the cluster configuration page, it will be automatically filled with the provided information. Then fill the form with the required information: If using Redhat, you can click on the Redhat button and follow the guide to create a service account and retrieve your Redhat Kafka cluster information. Please be careful to check that the files you are downloading from Aiven contain a proper key, and not, which happens when you don't have the permissions. ![]() Conduktor will generate files out of them in the folder you chose (don't remove them!). If using Aiven, you can use our integration to setup the configuration:ĭownload the 3 necessary files on Aiven's interface (service.key, service.cert, ca.pem). You can use the two buttons to test the Kafka and Zookeeper connectivity to ensure you connection details are accurate. For more information, please read the secure Kafka cluster section. Any additional properties you usually provide to your CLI or your Java clients should be inserted here.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |