General questions about Managed Service for Apache Kafka®
-
Why is the cluster slow even though the computing resources are not used fully?
-
Can I connect to cluster hosts via SSH or get superuser permissions on hosts?
-
Can I manage a cluster using scripts from a Apache Kafka® distribution?
-
What should I do if the kafkacat: command not found error occurs?
How do I ensure my cluster is fault tolerant?
Make sure it meets all fault tolerance conditions.
What should do I do if I get this or similar error: "disk size must be at least ... according to topics partitions number and replication factor, but size is ..."?
The error results from the fact that your topics' log segments take up more space than is available in broker storage. For more information about calculating the required space, see Minimum storage size.
To solve the issue, you can increase the disk size or reduce the topic segment or total cluster size.
Can I get the logs of what I do when I work with Yandex Cloud?
Yes, you can request information about operations with your resources from Yandex Cloud. For more information, see Data requests.
What is the retention period for logs?
Cluster logs are stored for 30 days.
How do I move a cluster to a different network?
You cannot move a Managed Service for Apache Kafka® cluster to another network.
Here is an alternative solution:
- Create a new cluster with the same configuration in the target network.
- Use MirrorMaker to move the topics of the source cluster to the new one.
How do I set up an alert that triggers as soon as a certain percentage of disk space has been used up?
Create an alert with the disk.used_bytes
metric in Yandex Monitoring. This metric shows the disk space usage in the Managed Service for Apache Kafka® cluster.
For disk.used_bytes
, use notification thresholds. The recommended values are as follows:
Alarm
: 90% of disk spaceWarning
: 80% of disk space
Thresholds are set in bytes only. For example, the recommended values for a 100 GB disk are as follows:
Alarm
:96636764160
bytes (90%)Warning
:85899345920
bytes (80%)
Why is the cluster slow even though the computing resources are not used fully?
Your storage may have insufficient maximum IOPS and bandwidth to process the current number of requests. In this case, throttling occurs, which degrades the entire cluster performance.
The maximum IOPS and bandwidth values increase by a fixed value when the storage size increases by a certain step. The step and increment values depend on the disk type:
Disk type | Step, GB | Max IOPS increase (read/write) | Max bandwidth increase (read/write), MB/s |
---|---|---|---|
network-hdd |
256 | 300/300 | 30/30 |
network-ssd |
32 | 1,000/1,000 | 15/15 |
network-ssd-nonreplicated , network-ssd-io-m3 |
93 | 28,000/5,600 | 110/82 |
To increase the maximum IOPS and bandwidth values and make throttling less likely, increase the storage size.
Can I connect to cluster hosts via SSH or get superuser permissions on hosts?
You cannot connect to hosts via SSH. This is done for the sake of security and user cluster fault tolerance because direct changes inside a host can render it completely inoperable.
What should I do if I get the revocation check error when using PowerShell to obtain an SSL certificate?
Here is the full text of the error:
curl: (35) schannel: next InitializeSecurityContext failed: Unknown error (0x80092012)
The revocation function was unable to check revocation for the certificate
This means, when connecting to the website, the service was unable to check whether or not its certificate was listed among revoked ones.
To fix this error:
-
Make sure the corporate network settings do not block the check.
-
Run the command with the
--ssl-no-revoke
parameter.mkdir $HOME\.kafka; curl.exe --ssl-no-revoke -o $HOME\.kafka\YandexInternalRootCA.crt https://storage.yandexcloud.net/cloud-certs/CA.pem
Can I manage a cluster using scripts from an Apache Kafka® distribution?
Yes, you can, but with some limitations.
For more information about the API types available in a cluster and applicable limitations, see APIs in Managed Service for Apache Kafka®.
For an example of using scripts, see Connecting to a Apache Kafka® cluster from applications.
What should I do if the kafkacat: command not found error occurs?
On Ubuntu 24.04 and higher, use kcat
instead of kafkacat
(this command will not work).