Using Kafka Services API

Two APIs are provided to check the health of Kafka services and change their status:

• HealthCheck

• KafkaService

HealthCheck

• This API provides the health status of all services related to Kafka.

• As part of the accelerator, we bundle Kafka, Zookeeper, Kafka Connect, and Schema Registry.

• If any of these services are not running, replication stops working.

  

HealthCheck API Access

To access the Healthcheck API, open the Swagger UI in your browser using the SinkConnector service URL:

http://{IP_Address}/Swagger/index.html

Replace {IP_Address} with the actual IP address of your SinkConnector service.

KafkaService

• This API is used to start, stop, or restart all Kafka services.

• If you encounter issues with any Kafka component or if any component is not running, you can use this API to manage the services.

  

Kafka UI Access

To monitor Kafka services visually, use the Kafka UI:

Kafka UI:http://{IP Address}/kafkaui

Replace {IP Address} with the actual IP address of your Kafka host.

Troubleshooting

1. Check Log Files:

   • Navigate to the folder: /opt/insightsoftware/hubble-accelerator/5.0.x/hubble-sinkconnector/logs/

   • Review the log files for any issues.

2. Identify Errors:

   • If any Kafka service fails to start, use the following commands to identify errors specific to the service:

     journalctl -xefu confluent-kafka-connect

     journalctl -xefu confluent-schema-registry

     journalctl -xefu confluent-confluent-zookeeper

     journalctl -xefu confluent-kafka

3. Restart the service.