Locomotor Activity Monitor

如有未包含create_time字段的数据表，请添加此字段；2. 对于activity数据表中已设置的外键，请按照指定次序依次执行。

Kafka Monitor 0.3.0 使用指南 Kafka Monitor 0.3.0 版本现已发布，您可以前往我的博客获取启动和使用方面的详细信息。博客中将深入探讨该版本的特性和功能，并提供配置和操作指南，帮助您更好地理解和使用 Kafka Monitor。

解码android-database-sqlcipher:3.5.7生成的加密数据库文件，使其可直接使用，操作简单有效。

发布订阅（pub/sub）消息通信模式致力于解耦消息发布者和订阅者，其原理类似观察者模式。它不仅消除代码层面的耦合，也消除物理部署上的关联。 Redis充当pub/sub服务器，负责消息路由。订阅者通过subscribe和psubscribe命令订阅感兴趣的消息类型，即Redis中的通道（channel）。发布者使用publish命令发送特定类型的消息，所有订阅该类型的客户端都会收到消息。 消息传递是多对多的，一个客户端可以订阅多个通道，也可以向多个通道发送消息。例如，三个客户端：client1订阅tv1通道，client2订阅tv1和tv2通道，client3发布tv1和tv2的消息。

由于我使用的是Maven，我将其直接打包成一个ZIP文件，以免有些人在查找JAR包时感到困惑。因此，您可以将此资源直接部署到Tomcat中运行。

功能改进：图表有时难以阅读，因为y轴图例上出现非整数，实际绘制的数据总是整数。将y轴设置为仅绘制整数，以使图表更易于解释。支持命令行参数kafkaOffsetForceFromStart，通过实现ConsumerRebalanceListener从日志的开头开始消费者偏移监听客户端。稳定性改进：创建tryParseOffsetMessage函数，尝试解析从内部提交的偏移主题检索到的kafka偏移消息：处理其他类型的消息和可疑正确性。为这个新函数添加了100%的单元测试覆盖率。增强日志末端偏移获取线程的健壮性：不再关闭应用程序错误。而是关闭和销毁客户端，然后重新创建它。在错误发生时休眠后重新创建客户端，并继续处理处理在线程之间共享内存的线程安全问题。