#Conduktor apache series series

Click the Create button and the helper will create the configuration for Conduktor to connect to your Aiven for Apache Kafka service.Ĭlick the Test Kafka Connectivity button to check that everything is working as expected. The three files downloaded: access key, access certificate and CA certificateĬonduktor will create the keystore and truststore files in the folder that you specified, or you can choose an alternative location. Host and port, you can copy these from the Service overview page This pops up a helper screen so that you can add all the information needed for Aiven in a friendly format. Visit the Service overview page for your Aiven for Apache Kafka® service (the Getting started with Aiven for Apache Kafka® page is a good place for more information about creating a new service if you don’t have one already).ĭownload the Access Key, Access Certificate and CA Certificate (if you didn’t have that already) into a directory on your computer.Ĭhoose New Kafka Cluster on the main pane, and click the Aiven icon. You will need to add the CA certificate for each of your Aiven projects to Conduktor before you can connect, this is outlined in the steps below. In fact, there is built-in support for setting up the connection. Use Google Private Service Connect with Aiven servicesĬonnect to Apache Kafka® with Conduktor #Ĭonduktor is a friendly user interface for Apache Kafka, and it works well with Aiven.Use Azure Private Link with Aiven services.Use AWS PrivateLink with Aiven services.Set up network peering between Aiven and UpCloud.Set up Virtual Private Cloud (VPC) peering on AWS.Set up Virtual Private Cloud (VPC) peering on Google Cloud Platform (GCP).In Apache Kafka, offsets are used to track the progress of a consumer group.

#Conduktor apache series series

Manage Virtual Private Cloud (VPC) peering This is the first of a two part series on monitoring a Kafka cluster.Handle resolution errors of private IP addresses.Default service IP address and hostname.Firewall configuration for service nodes.