下面通过一个简单的示例向您展示 Event Store 的基本功能操作，以帮助您快速进行理解。

操作步骤一

登录您集群中的一台安装了 Event Store 的节点。进入对应 Client 目录下，执行初始化操作
```
cd /root/TDH-Client/
source ./init.sh y y
```
操作步骤二

进入对应 TDH-Client/kafka/bin 路径下，该目录下有建 Kafka 数据源所需要的一些脚本。

操作步骤三：创建 Topic

执行下面的指令，运行 client 目录下（一般为 /root/TDH-Client/kafka/bin/）的 kafka-topics.sh 脚本:

/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic demo
--partitions 3 --replication-factor 1 (1)

Created topic "demo". (2)

1	使用 172.16.1.128 上的 Zookeeper 创建 Topic，分 3 个 partition。
2	该 topic 名称为 demo

如果您的 EventStore 服务处在安全模式下,你需要另外提供创建 topic 用户的 principal 和 keytab，并且该用户需要有创建 topic 的权限。具体操作请参考

操作步骤四：查看 Topic

执行下面指令，运行 /usr/lib/kafka/bin 目录下的 kafka-topics.sh 脚本：

./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic demo

Topic:demo PartitionCount:3 ReplicationFactor:1 Configs:

Topic: demo Partition: 0 Leader: 4 Replicas: 4 Isr: 4

Topic: demo Partition: 1 Leader: 5 Replicas: 5 Isr: 5

Topic: demo Partition: 2 Leader: 6 Replicas: 6 Isr: 6

我们可以看到刚才建的名为 demo 的 topic 和一些相关信息，这些信息会在之后的介绍中解释。

操作步骤五：创建 producer 并发布消息

执行下面指令，运行 /usr/lib/kafka/bin 目录下的 kafka-console-producer.sh 脚本：
```
./kafka-console-producer.sh --broker-list 172.16.1.28:9092 --topic demo
```
这里我们指定了使用 172.16.1.128 节点为 Kafka broker（详细介绍见后文），并且指定了 producer 发布消息的 topic 为 demo。

现在，我们可以在命令行中输入一些消息，这些消息都将被发布给 demo：
```
hello

world
```
操作步骤六

至此，我们已经建好了一个 Event Store 数据源，并发布了一些消息。

先不要停止上面 producer 的进程，让它保持运行，您可以继续在命令行中输入消息。现在您可以打开另一个窗口进行消息的消费。

操作步骤七：创建 consumer 并消费消息

执行下面的指令，运行 /usr/lib/kafka/bin 目录下的 kafka-console-consumer.sh 脚本：

./kafka-console-consumer.sh --bootstrap-server 172.16.1.28:9092 --topic
demo --from-beginning (1)

1	--from-beginning 表示从 topic 的最开始的位置进行消费，如果没有指定该参数，表示从末尾开始消费，只有当启动消费者后，有新的数据写入，才能够显示到控制台。