Commandes de création de sujets Kafka couramment utilisées

1. Créez un sujet en utilisant la ligne de commande

kafka-topics --create --topic test --partitions 3 --replication-factor 2

Cette commande créera un sujet nommé "test" avec 3 partitions et 2 facteurs de réplication. Cela signifie que les données seront répliquées 3 fois sur 2 courtiers différents pour garantir la redondance et la haute disponibilité.

2. Créez un sujet à l'aide de l'API Java

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient adminClient = AdminClient.create(props);

NewTopic topic = new NewTopic("test", 3, (short) 2);
adminClient.createTopics(Arrays.asList(topic));

Ce code créera un sujet nommé "test" avec 3 partitions et 2 facteurs de réplication.

3. Créez un sujet à l'aide de l'API Python

from kafka import KafkaAdminClient

admin_client = KafkaAdminClient(bootstrap_servers="localhost:9092")

topic_list = [
    kafka.admin.NewTopic(name="test", num_partitions=3, replication_factor=2)
]

admin_client.create_topics(new_topics=topic_list, validate_only=False)

Ce code créera un sujet nommé "test" avec 3 partitions et 2 facteurs de réplication.

4. Créez un sujet à l'aide de l'API REST

curl -X POST -H "Content-Type: application/json" -d '{"name": "test", "partitions": 3, "replication_factor": 2}' http://localhost:8083/topics

Cette commande créera un sujet nommé "test" avec 3 partitions et 2 facteurs de réplication.

5. Créez un sujet à l'aide de l'interface utilisateur de Kafka

1. Ouvrez l'interface utilisateur de Kafka sur http://localhost:8083.
2. Cliquez sur l'onglet "Thèmes".
3. Cliquez sur le bouton "Créer un thème".
4. Dans le champ Nom, saisissez un nom pour votre thème.
5. Dans le champ "Nombre de partitions", saisissez le nombre de partitions.
6. Dans le champ "Replication Factor", saisissez le facteur de réplication.
7. Cliquez sur le bouton "Créer".

Le thème sera créé et vous le verrez dans la liste des thèmes.

Autres options

En plus des méthodes ci-dessus, vous pouvez également créer un sujet en utilisant les options suivantes :

• Utilisation du [proxy REST Kafka](https://kafka.apache.org/documentation/#rest_proxy )
• Utilisation du [Package Kafka Python](https://github.com/dpkp/kafka-python)
• Utilisation du [Package Kafka Go](https://github.com/Shopify/sarama)
• Utilisation de [Kafka Package Node.js](https://github.com/segmentio/kafka-node)

Notes

• Lors de la création d'un sujet, vous devez vous assurer que le nom du sujet est unique.
• Vous devez également vous assurer que le nombre de partitions et le facteur de réplication sont compatibles avec les besoins de votre application.
• Si vous créez un sujet avec un grand nombre de partitions, vous risquez de rencontrer des problèmes de performances.
• Si vous créez un sujet avec un facteur de réplication important, vous risquez d'augmenter la surcharge de stockage.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!