点击下载《Kafka服务端(含Zookeeper)一键自启软件》
点击下载《kafka客户端生产者消费者kafka可视化工具（可生产和消费消息）》
点击下载《Kafka自动生产消息软件》

1. 前言

在软件开发过程中，Kafka常被用作消息队列来处理特定的业务功能。为了测试程序在高负载下的处理能力和健壮性，开发人员通常需要编写额外的代码来模拟消息的生产和消费。然而，对于不具备编码能力的测试人员来说，这无疑是一大难题。为了解决这一问题，我们推出了《Kafka自动生产消息》工具，它能够通过简单的配置实现高频率地生产消息。

2. 软件介绍

2.1 连接配置

• Bootstrap Server: 配置Kafka服务地址，支持集群模式，多个地址以英文逗号分隔，例如：127.0.0.1:9092,127.0.0.1:9093。
• UserName: Kafka认证配置的用户名。如果服务端未配置认证机制，则留空。
• Password: Kafka认证配置的密码。如果服务端未配置认证机制，则留空。

注意事项:

1. 当前用户名密码配置仅支持认证协议为SASL_PLAINTEXT，SASL机制为PLAIN。

2. 修改配置并保存后，生产者和消费者将使用新的配置进行生产和消费消息。

2.2 配置Topic

在连接配置正确填写并保存后，用户可以进入Topic配置界面。在这里，用户可以新增、修改、复制、删除Topic，并对Topic进行排序。

• Topic: 必填项，定义消息的类别，消息被发布到特定的 Topic，然后可以被一个或多个消费者订阅和消费，Topic 使得消息的发布和订阅变得有序和可管理。Topic 是分区的，这意味着一个 Topic 可以分布在多个 Kafka broker 上，以提高并行处理能力和系统的可扩展性。
• Key: 可选项，它是与消息相关联的键，可以用来决定消息应该被发送到 Topic 的哪个分区。如果未指定 Key，消息将被随机分配到 Topic 的分区中。
• Message: 必填项，它是 Kafka 中传输的数据单元，包含消息的实际内容以及一些可选的元数据。
• Type: 指定消息内容的格式，可选择文本或JSON格式。

2.3 开始执行

配置完成后，点击【启动】按钮即可开始执行Kafka消息生产操作。程序将按照Topic配置列表的顺序依次执行状态为【启用】的Topic记录。

2.4 查看日志

程序在执行过程中会自动切换至日志查看界面，用户可以实时查看每个Topic消息的生产明细。日志界面提供了【开始】按钮，与生产消息界面的【开始】按钮功能相同。

当日志内容过多时，用户可以点击【清空日志】来清理当前日志内容。点击【保存为文件】可以将当前日志内容保存为log文件。如果未手动保存日志记录，程序会在可执行目录下的Log/LogInfo文件夹中保留所有执行的日志记录。

最后，我们分别使用Kafka消息消费软件和Kafka Offset Explorer消费一下，可以看到确实是成功了。

3. 总结

该C#开发的自动化Kafka消息生成程序为用户提供了一个高效、灵活的消息生成工具。通过集成Kafka连接配置、消息自动生成配置和日志记录功能，程序能够满足用户在测试和开发过程中对Kafka消息生成的需求。随机生成的消息内容以及实时日志查看功能进一步增强了程序的功能性和用户体验，使得消息生成过程更加便捷和可控。

点击下载《Kafka服务端(含Zookeeper)一键自启软件》
点击下载《kafka客户端生产者消费者kafka可视化工具（可生产和消费消息）》
点击下载《Kafka自动生产消息软件》