Cómo crear un tema en Kafka

[Toc]

Antes de usar Kafka para enviar y consumir mensajes, primero debes crear un tema. Hay tres formas de crear un tema en Kafka:

Cree un tema llamado topic-test1 mediante el script kafka-topics.sh, que contiene 2 réplicas y 4 particiones. (A menos que se indique lo contrario, este artículo se basa en la versión 1.0.0)

Abra el script kafka-topics.sh, que es un script de una línea que se ve así:

La parte principal del script El propósito es ejecutar kafka.admin.TopicCommand. En el método principal, determinará si existe una creación en la lista de parámetros y, de ser así, realizará la tarea de crear el tema.

Al crear un tema, además de los parámetros de dirección del cuidador del zoológico, también debe especificar el nombre del tema, el factor de replicación, el número de particiones y otros parámetros requeridos, que también pueden incluir desactivar el rack-aware, config, if- Parámetros opcionales como no existe, así como parámetros opcionales como enable-rack-aware, config, if-not-exists, etc.

Al crear un tema, Kafka emitirá una advertencia si el nombre contiene o _. Este es el motivo:

Internamente, Kafka oculta las métricas según el nombre del tema y cambia los puntos a guiones bajos _ . Supongamos que encuentra un tema llamado topic.1_2 y otro tema llamado topic_1.2, entonces el nombre de la última métrica es topic_1_2, por lo que hay un conflicto de nombres.

No recomendamos (aunque es posible) nombrar temas que comiencen con un doble guión bajo __, porque los temas que comienzan con un doble guión bajo generalmente se consideran temas internos de Kafka, como __consumer_offsets y __transaction_state.

Los nombres de los temas deben cumplir las siguientes reglas: