个人技术分享

【JAVA】Java如何连接消费Kafka

在现代数据驱动的世界中，实时数据流处理已经成为许多应用的核心部分。Apache Kafka是一个分布式流处理平台，被广泛用于实时数据流处理、日志聚合和实时分析。在这篇博客中，我们将探讨如何使用Java来连接并消费Kafka的消息。在这篇博客中，我们讨论了如何使用Java来连接并消费Kafka的消息。我们首先解释了KafkaConsumer的主要函数和配置，然后给出了一个基本的示例代码。希望这篇博客能帮助你理解如何在Java中使用Kafka。

18.分布式监控zabbix-proxy

配置agent内网地址172.16.1.12主机，因是内网地址无法直接通过xshell连接，通过proxy去连接agent进行修改配置文件，如下配置。查看192.168.111.66主机上的数据库zabbix_proxy已经存在数据了，导入数据成功；如果未添加自动注册，就直接手动去添加主机即可，创建主机都一致，区别就在于agent代理程序检测选择；配置zabbix-server界面管理-agent代理程序-创建代理配置如下。查看zabbix-server界面上配置-主机查看proxy代理监控内网成功。

Kafka 实战 - Kafka Consumer 重置 Offset

使用AdminClient.resetOffsets()方法，指定消费者组、偏移量规格（基于目标时间点）以及受影响的TopicPartition，执行偏移量重置操作。在开发测试过程中，可能需要消费一段时间的消息，来验证数据的可靠性，这里需要消费者（Consumer）重置其消费的偏移量（Offset）。--to-datetime: 设置重置偏移量的目标时间点。--all-topics: 重置该消费者组订阅的所有Topic的偏移量。--reset-offsets: 表示要执行偏移量重置操作。