重庆市建设项目环境申报表网站电商网站建设综述

张小明 2026/3/12 12:38:15
重庆市建设项目环境申报表网站,电商网站建设综述,核名查询系统,中国优秀设计网站Spring Boot 整合 Kafka 进行日志处理是一个常见的任务#xff0c;可以帮助你更好地管理和分析应用程序的日志。以下是一个基本的步骤指南#xff0c;帮助你完成这个整合。 本文介绍了如何在SpringBoot应用中整合Kafka#xff0c;利用Logback收集日志并发送到Kafka。详细步…Spring Boot 整合 Kafka 进行日志处理是一个常见的任务可以帮助你更好地管理和分析应用程序的日志。以下是一个基本的步骤指南帮助你完成这个整合。本文介绍了如何在SpringBoot应用中整合Kafka利用Logback收集日志并发送到Kafka。详细步骤包括添加Kafka相关依赖配置logback.xml自定义KafkaAppender以及提供测试。首先安装kafka.。之前已经安装过了我们这里不再讲。可以参考前面讲的类容https://blog.csdn.net/lchmyhua88/article/details/155640953?spm1001.2014.3001.5502接着我们按照下面的步骤开始1.pom依赖2.logback.xml配置3.配置 kafka消费者4.监听消费消息测试代码1. 添加依赖!-- Spring Boot Starter Kafka -- dependency groupIdorg.springframework.kafka/groupId artifactIdspring-kafka/artifactId /dependency !-- Logback Kafka Appender -- dependency groupIdcom.github.danielwegener/groupId artifactIdlogback-kafka-appender/artifactId version0.2.0-RC2/version /dependency !-- Kafka Clients -- dependency groupIdorg.apache.kafka/groupId artifactIdkafka-clients/artifactId version3.0.0/version /dependency2.配置 Logbackconfiguration !-- 控制台输出appender -- appender nameCONSOLE classch.qos.logback.core.ConsoleAppender encoder pattern%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n/pattern /encoder /appender !-- Kafka appender -- appender nameKAFKA classcom.github.danielwegener.logback.kafka.KafkaAppender encoder classch.qos.logback.classic.encoder.PatternLayoutEncoder pattern%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n/pattern /encoder !-- Kafka topic名称 -- topiclog-topic/topic !-- Kafka bootstrap servers -- keyingStrategy classcom.github.danielwegener.logback.kafka.keying.NoKeyKeyingStrategy / deliveryStrategy classcom.github.danielwegener.logback.kafka.delivery.AsynchronousDeliveryStrategy / !-- Kafka producer配置 -- producerConfigbootstrap.servers192.168.33.10:9092/producerConfig producerConfigacks0/producerConfig producerConfiglinger.ms1000/producerConfig producerConfigmax.block.ms0/producerConfig !-- 过滤器设置可选 -- filter classch.qos.logback.classic.filter.ThresholdFilter levelINFO/level /filter /appender !-- 根logger配置 -- root levelINFO appender-ref refCONSOLE/ appender-ref refKAFKA/ /root /configuration3.配置 kafka消费者为了方便测试我们把生产者消费者都配置上spring.kafka.bootstrap-servers192.168.33.10:9092 #spring.kafka.consumer.group-idmy-group spring.kafka.consumer.auto-offset-resetearliest spring.kafka.consumer.enable-auto-committrue spring.kafka.consumer.key-deserializerorg.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-deserializerorg.springframework.kafka.support.serializer.JsonDeserializer spring.kafka.consumer.properties.spring.json.trusted.packages* spring.kafka.producer.key-serializerorg.apache.kafka.common.serialization.StringSerializer spring.kafka.producer.value-serializerorg.springframework.kafka.support.serializer.JsonDeserializer4.注入kafka bean ,方便后面调试生产者。Configuration public class KafkaProducerConfig { Value(${spring.kafka.bootstrap-servers}) private String bootstrapServers; Bean public ProducerFactoryString, Object producerFactory() { MapString, Object configProps new HashMap(); configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers); configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class); configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class); return new DefaultKafkaProducerFactory(configProps); } Bean public KafkaTemplateString, Object kafkaTemplate() { return new KafkaTemplate(producerFactory()); } }5.监听消费消息Component public class LogConsumer { KafkaListener(topics log-topic,groupId my-group) public void listen(String message) { System.out.println(收到日志消息: message); } }6.添加日志打印RestController RequestMapping(/kafka) public class LogController { Autowired private KafkaProducerServiceImpl producerService; private static final Logger logger (Logger) LoggerFactory.getLogger(LogController.class); GetMapping(/log) public String log() { //producerService.sendLogMessage(This is a test log message); logger.info(这是一条测试日志消息); logger.warn(这是一条警告日志消息); logger.error(这是一条错误日志消息); return Log message sent; } }下面我们开始测试通过调用接口控制台可以看到我写3条日志kafka消费3条消息这样我们就通过logback把日志收集到kafka里面。方便数据分析。当然你也可以写入es进行分析画像。我们可以通过kafka manger控制台来监控消息。下载kafka-manager下载地址 https://github.com/yahoo/kafka-manager解压后配置application.conf kafka地址保存后指定8888端口启动bin/kafka-manager -Dconfig.fileconf/application.conf -Dhttp.port8888启动后打开控制面板可以看到kafka集群节点信息和分区消费偏移等信息http://192.168.33.10:8888/详情可以去官网看看介绍https://github.com/yahoo/CMAK
版权声明:本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!

济南物流公司网站建设网页广告投放

打开IDE写代码时被自动补全惊艳,用工具生成需求文档时感叹高效,甚至调试Bug时都能靠AI快速定位问题——如今,人工智能大模型早已不是遥远的概念,而是渗透在程序员工作流、生活场景中的“刚需伙伴”。对于刚入门的小白或想拓展技能…

张小明 2026/3/5 5:23:12 网站建设

百度搜索网站怎么做常州市城市建设局网站

今日收获:1.随几过程(独立增量,泊松过程,严平稳)2.Redis数据持久化(RDB AOF 以及 AOF重写的优化——混合持久化)下午去图书管学了一会,主要看了写了几个数学题。

张小明 2026/3/5 3:51:39 网站建设

医疗机构网站模板网页源代码模板

EmotiVoice语音合成在虚拟现实环境中的沉浸式体验增强 在虚拟现实的世界里,一个角色的眼神、动作甚至语气,都在悄然影响着用户的代入感。然而长久以来,语音交互始终是沉浸感链条上的薄弱一环——机械的朗读腔调、千篇一律的声音模板&#xff…

张小明 2026/3/5 5:23:44 网站建设

网站概念设计微网站第三方平台

在3D打印和数字制造领域,精确计算模型的体积、表面积和质量是每个设计师和工程师必须面对的重要任务。STL体积模型计算器作为一款功能强大的Python命令行工具,能够快速分析STL、NIfTI和DICOM格式文件,提供全面的模型属性数据,让3D…

张小明 2026/3/5 3:51:45 网站建设

做啥网站北京seowyhseo

快速体验 打开 InsCode(快马)平台 https://www.inscode.net输入框内输入如下内容: 编写一个性能对比脚本,分别用传统手动剪辑和MoviePy自动化处理相同的宣传视频项目(包含:片头动画、5个章节转场、字幕添加、背景音乐混音&#x…

张小明 2026/3/5 5:48:46 网站建设

网站免备案空间dokuwiki wordpress 整合

React图标库革命:告别图标选择困难症的神奇解决方案 【免费下载链接】react-icons svg react icons of popular icon packs 项目地址: https://gitcode.com/gh_mirrors/re/react-icons 你是否曾在项目中为了寻找合适的图标而花费数小时?是否因为不…

张小明 2026/3/5 6:11:45 网站建设