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.
Conduktor kafka series accelsawersventurebeat how to#
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. additional properties: this is one of the most important section, especially if you have a secure Kafka cluster. In the form of zookeeper1-url:2181,zookeeper2-url:2181 Over time, as Kafka migrates away from using Zookeeper, this configuration will become less and less necessary to provide. zookeeper (optional): providing a Zookeeper URL will allow you to access more features through Conduktor, for example partition reassignment. bootstrap servers: list of Kafka brokers to connect to, usually providing two or three brokers is enough. cluster name: this will be the name of your cluster when navigating the list of clusters on the right-hand side of the Conduktor splash screen. In case you're not using those, rest assured you can connect to your cluster! integration: in case you are using Aiven, Confluent Cloud or Redhat Openshift, you have the possibility to quickly integrate with them through a dialog. 
This tab is the most important tab, and you have the following options: This will open up a list of configurations you can set for Conduktor To add a cluster, please click on the "Add new cluster" button Setting up a connection to Kafka Adding a Cluster
0 kommentar(er)
