新都在 - Carol 小屋

精选教程未读

本文介绍了如何使用logstash来监控文件并将数据传输到Elasticsearch（ES）。在配置文件中，我们使用logstash的File Input插件来监听指定路径下的txt文件。由于文件中的每一行都是一个标准的json格式，我们可以选择将codec设置为json，以便正确解析每行数据。在filter部分，我们使用mutate插件中的gsub方法，将消息中的换行符替换为实际的换行符。最后，在output部分，我们配置了ES的连接信息以及将数据存储到ES中的索引名称。通过这样的配置，logstash能够实现监听文件并将数据传输到ES的功能。这种方法可以适用于需要从文本文件中读取数据并进行分析和存储的场景。

elasticsearch 2023-07-26

精选教程常用工具未读

激活Navicat Premium 15

本文详细介绍了如何激活Navicat Premium 15。首先，准备工作包括下载Navicat Premium 15安装包和专用破解工具。安装Navicat Premium 15后，使用破解工具生成credit验证和keygen。然后，在Navicat中选择"帮助"菜单下的"注册"选项，将生成的keygen粘贴到激活页面中。点击"激活"按钮后选择"手动激活"，将请求码复制到破解工具中生成激活码，最后将激活码粘贴到Navicat激活页面中完成激活过程。整个过程详细展示了每个步骤的截图，确保用户能够成功激活Navicat Premium 15。请注意，该方法仅适用于个人学习和了解Navicat软件的目的。侵犯软件版权是违法行为，请遵守当地法律法规。

database 2023-07-26

精选教程未读

使用logstash将kafka中的元数据写入到es中

本文主要介绍了如何使用logstash将kafka中的元数据写入到Elasticsearch（ES）中。在logstash的配置文件中，我们可以通过修改filter的mutate属性来操作元数据。通过设置`decorate_events`为`true`，可以获取到kafka中的一些重要元数据，如topic、consumer_group、partition、offset、key和timestamp。其中，我们可以使用`mutate`中的`split`方法和`add_field`方法，将kafka的key进行切割并将切割后的数据存放到自定义字段中。最后，配置output的部分，将数据输出到ES中。通过这样的配置，我们可以实现将kafka中的元数据写入到ES的目的。该方法在logstash 7.3版本以上，且匹配kafka 2.0以上的版本均可使用。

elasticsearch 2023-07-26

精选教程未读

Topic基本操作

本文详细介绍了在Linux服务器上使用Kafka进行操作的基本命令和步骤。首先，通过`locate kafka-topics.sh`命令找到Kafka安装位置，然后配置`service.properties`文件中的参数，如`partitions`和`replication-factor`来定义topic的分区和副本数。接下来，演示了创建、查看、生产和消费Kafka topic的命令，包括使用`bin/kafka-topics.sh`和`bin/kafka-console-producer.sh`来发送数据，以及使用`bin/kafka-console-consumer.sh`查看数据。此外，还展示了如何查看topic分区的偏移量，以及如何通过`bin/kafka-topics.sh --alter`命令增加topic的分区数。最后，提醒了删除topic时需谨慎操作，只删除ZooKeeper中的元数据，而消息文件需要手动删除。文章通过这些操作指导读者如何有效地管理和监控Kafka中的topic和消息流。

linux 2023-07-26

后端未读

Java岗大厂面试百日冲刺【Day11】 —— MyBatis1