Schritte zum Erstellen eines Kafka-Themas: Verwenden von Kafka-Befehlen

Schritte zum Erstellen eines Themas mit Kafka-Befehlen

1. ZooKeeper- und Kafka-Dienste starten

zookeeper-server-start.sh config/zookeeper.properties
kafka-server-start.sh config/server.properties

2. Ein Thema erstellen

kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

3. Thema ansehen

kafka-topics.sh --list

4. Senden zum Thema Nachrichten

kafka-console-producer.sh --topic my-topic --message "Hello, world!"

5. Nachrichten aus dem Thema verbrauchen

kafka-console-consumer.sh --topic my-topic --from-beginning

Spezifische Codebeispiele

# 启动ZooKeeper服务
zookeeper-server-start.sh config/zookeeper.properties

# 启动Kafka服务
kafka-server-start.sh config/server.properties

# 创建主题
kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

# 查看主题
kafka-topics.sh --list

# 向主题发送消息
kafka-console-producer.sh --topic my-topic --message "Hello, world!"

# 从主题消费消息
kafka-console-consumer.sh --topic my-topic --from-beginning

Notizen

• Beim Erstellen eines Themas müssen Sie den Namen angeben Thema, das Anzahl der Partitionen und die Anzahl der Replikate.
• Die Anzahl der Partitionen bestimmt, wie viele Nachrichten das Thema gleichzeitig verarbeiten kann.
• Die Anzahl der Kopien bestimmt, wie viele Kopien der Themendaten vorhanden sind.
• Wenn Sie eine Nachricht an ein Thema senden, müssen Sie den Schlüssel und den Wert der Nachricht angeben.
• Beim Konsumieren von Nachrichten aus einem Thema können Sie eine Verbrauchergruppe angeben. Verbraucher in der Verbrauchergruppe konsumieren gemeinsam die Nachrichten im Thema.

Das obige ist der detaillierte Inhalt vonSchritte zum Erstellen eines Kafka-Themas: Verwenden von Kafka-Befehlen. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!