6.交易属性 键 默认值 描述 spring.jta.atomikos.connectionfactory.borrow-connection-timeout 30 从池借用连接的超时时间（以秒为单位）。 spring.jta.atomikos.connectionfactory.ignore-session-transacted-flag true 创建会话时是否忽略事务标记。 spring.jta.atomikos.connectionfactory.local-transaction-mode fa
Kafka、Logstash、Nginx日志收集入门 Nginx作为网站的第一入口，其日志记录了除用户相关的信息之外，还记录了整个网站系统的性能，对其进行性能排查是优化网站性能的一大关键。 Logstash是一个接收，处理，转发日志的工具。支持系统日志，webserver日志，错误日志，应用日志，总之包括所有可以抛出来的日志类型。一般情景下，Logstash用来和ElasticSearch和Kibana搭配使用，简称ELK，本站http://www.wenzhihuai.com除了用作ELK，还配合了K
Nginx作为网站的第一入口，其日志记录了除用户相关的信息之外，还记录了整个网站系统的性能，对其进行性能排查是优化网站性能的一大关键。 Logstash是一个接收，处理，转发日志的工具。支持系统日志，webserver日志，错误日志，应用日志，总之包括所有可以抛出来的日志类型。一般情景下，Logstash用来和ElasticSearch和Kibana搭配使用，简称ELK。 kafka是一个分布式的基于push-subscribe的消息系统，它具备快速、可扩展、可持久化的特点。它现在是Apache旗下的一个开源系统，作为hadoop生态系统的一部分，被各种商业公司广泛应用。它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/spark流式处理引擎。 下面是日志系统的搭建
常用应用属性 可以在application.properties / application.yml file中指定各种属性，也可以在命令行开关中指定。本节提供了常见的Spring Boot属性和对使用它们的基础类的引用的列表。 摘自：http://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html ＃========================================
Kafka是由LinkedIn开发并开源的分布式消息系统,因其分布式及高吞吐率而被广泛使用,现已与Cloudera Hadoop,Apache Storm,Apache Spark集成，具备许多优秀的性能：高吞吐、分布式、跨平台、实时性以及伸缩性，本文我们就来看看如何将Spring Cloud Bus和Kafka进行整合。 ---- Kafka下载 Kafka现在是Apache上的开源项目，直接到官网下载即可(http://kafka.apache.org/)，这个不用我多说。 启动 下载成功之后，是一
作者 | Johan Janssen 译者 | 明知山 策划 | 丁晓昀 VMWare 发布 Spring for Apache Kafka 3.0 和 Spring for RabbitMQ 3.0，需要 Java 17 和 Spring Framework 6.0。这些项目现在支持创建原生 GraalVM 应用程序，并使用 Micrometer 指标门面来观察计时器和实现跟踪。现在，两个项目都在 pom.xml 文件中提供了 BOM，方便进行依赖项管理。 Micrometer 用于增强 JV
如果你对Flink CDC 还没有什么概念，可以参考这里：Flink CDC 原理及生产实践。
在实际应用中，往往需要根据业务需求动态开启/关闭Kafka消费者监听。例如，在某些时间段内，可能需要暂停对某个Topic的消费，或者在某些条件下才开启对某个Topic的消费。
Spring Boot 3.2 昨日发布，让我们用 Java 21、GraalVM 和虚拟线程来尝试一下。
作为Apache Kafka深挖的博客系列第1部分和第2部分的后续,在第3部分中我们将讨论另一个Spring 团队的项目:Spring Cloud Data Flow,其重点是使开发人员能够轻松地开发、部署和协调事件流管道基于Apache Kafka。作为前一篇博客系列文章的延续，本文解释了Spring Cloud数据流如何帮助您提高开发人员的工作效率并管理基于apache - kafka的事件流应用程序开发。
Git JDK 1.8.0 及以上 maven 3.3 及以上 Docker for Windows IDEA
我们数据库中的数据一直在变化，有时候我们希望能监听数据库数据的变化并根据变化做出一些反应，比如更新对应变化数据的缓存、增量同步到其它数据源、对数据进行检测和审计等等。而这种技术就叫变更数据捕获（Change Data Capture）。对于这种技术我们可能知道一个国内比较知名的框架Canal，非常好用！但是Canal有一个局限性就是只能用于Mysql的变更数据捕获。今天来介绍另一种更加强大的分布式CDC框架Debezium。
本文是 Spring Boot 运行源码剖析内容，内容夹杂了不少的 Spring Boot 源代码片段。
学习命令的正确方式，其实是先手动操作一个简单的命令，然后了解命令的基本含义，然后再看命令的相关文章。
2. IOC 的意思是控制反转，是指创建对象的控制权的转移，以前创建对象的主动权和时机是由自己把控的，而现在这种权力转移到 Spring 容器中，并由容器根据配置文件去创建实例和管理各个实例之间的依赖关系，对象与对象之间松散耦合，也利于功能的复用。最直观的表达就是，IOC 让对象的创建不用去 new 了，可以由 spring 根据我们提供的配置文件自动生产，我们需要对象的时候，直接从 Spring 容器中获取即可.
前段时间，我负责在所属的一个团队内部去推动一项叫做“Testcontainers”的技术。于是在调研并打磨了数天之后，就诞生下文。希望看完本篇文章的你，能够有所收获，感谢阅读！
又到了写年终总结的时候了。每当这个时候思绪总是翻江倒海，因为太久没有反思和总结的缘故，一年才总结一次，确实是有点久，欠的账的太多，梳理起来有点费劲。这里依旧还是写跟点跟工作/技术相关的总结。
logging.config= # Location of the logging configuration file. For instance classpath:logback.xml for Logback logging.exception-conversion-word=%wEx # Conversion word used when logging exceptions. logging.file= # Log file name. For instance myapp.log logging.level.*= # Log levels severity mapping. For instance logging.level.org.springframework=DEBUG logging.path= # Location of the log file. For instance /var/log logging.pattern.console= # Appender pattern for output to the console. Only supported with the default logback setup. logging.pattern.file= # Appender pattern for output to the file. Only supported with the default logback setup. logging.pattern.level= # Appender pattern for log level (default %5p). Only supported with the default logback setup. logging.register-shutdown-hook=false # Register a shutdown hook for the logging system when it is initialized.
作者 | Jason Greene, John Clingan, Eric Deandrea
翻译自 Unveiling the Future of Application Networking: Trends and Impacts 。
在这个博客系列的第1部分之后，Apache Kafka的Spring——第1部分:错误处理、消息转换和事务支持，在这里的第2部分中，我们将关注另一个增强开发者在Kafka上构建流应用程序时体验的项目:Spring Cloud Stream。
许多人使用容器来包装他们的 Spring Boot 应用程序，而构建容器并不是一件简单的事情。这是针对 Spring Boot 应用程序开发人员的指南，容器对于开发人员来说并不总是一个好的抽象。它们迫使你去了解和思考低层次的问题。但是，有时可能会要求您创建或使用容器，因此了解构建块是值得的。在本指南中，我们旨在向您展示如果您面临需要创建自己的容器的前景，您可以做出的一些选择。
◆ 一、开源项目简介 滴滴LogiAM来源于滴滴多年来大量的运维实践经验。经历过多方考验，对于大规模Agent日志采集治理管控及巡检诊断已经沉淀出一套完善的解决方案。在云原生时代背景下，LogiAM以“应用/服务”为采集粒度，满足了从业务层面创建采集任务的需求。 ◆ 二、开源协议 使用Apache-2.0开源协议 ◆ 三、界面展示 ◆ 四、功能概述 ◆ 用户体验地图 主机/容器管理：用于维护主机、容器信息至系统(含:容器-主机关系) 服务管理：用于维护服务信息至系统(含:服务-主机、服务-容器关系)
spring boot2.x已经出来好一阵了，而且spring cloud 的最新Release版本Finchley.RELEASE，默认集成的就是spring boot 2.x，这几天将一个旧项目尝试着从低版本升级到 2.x，踩坑无数，记录一下：
从0.6.0版本开始，Hudi开始支持 commit 回调功能，即每当Hudi成功提交一次 commit, 其内部的回调服务就会向外部系统发出一条回调信息，用户可以根据该回调信息查询Hudi表的增量数据，并根据具体需求进行相应的业务处理。
A： 多年来，随着新功能的增加，spring变得越来越复杂。只需访问页面https://spring.io/projects，我们将看到所有在应用程序中使用的不同功能的spring项目。如果必须启动一个新的spring项目，我们必须添加构建路径或maven依赖项，配置application server，添加spring配置。因此，启动一个新的spring项目需要大量的工作，因为我们目前必须从头开始做所有事情。Spring Boot是这个问题的解决方案。Spring boot构建在现有Spring框架之上。使用spring boot，我们可以避免以前必须执行的所有样板代码和配置。因此，Spring boot帮助我们更健壮地使用现有的Spring功能，并且只需最少的工作量。
Spring Cloud Data Flow（SCDF）是一个用于构建、部署和管理数据处理管道的开源平台。它提供了一组标准化的组件和工具，可以用于构建、部署和监控复杂的数据处理管道，并且支持多种数据处理引擎和平台，包括 Spring Cloud Stream、Spring Cloud Task、Apache Spark、Apache Kafka 等。
点击关注公众号，Java干货及时送达 Spring Boot 2.6.0 来了 太猛了！Spring Boot 2.5.6 发布不到一个月，Spring Boot 又接连发布了三个版本： Spring Boot 2.6.0（最新） Spring Boot 2.5.7 Spring Boot 2.4.13 后面两个版本都是修复 bug 版本，2.6.0 才是硬菜。。 ---- 先给大家奉上几个版本的 Maven 依赖： Spring Boot 2.6.0： <dependency> <groupId>
WebSocket网上很多教程，这里不详细描述。简单来说：WebSocket协议是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工(full-duplex)通信——允许服务器主动发送信息给客户端。
kafka 是一个消息队列产品，基于 Topic partitions 的设计，能达到非常高的消息发送处理性能。Spring 创建了一个项目 Spring-kafka，封装了 Apache 的 Kafka-client，用于在 Spring 项目里快速集成 kafka。除了简单的收发消息外，Spring-kafka 还提供了很多高级功能，下面我们就来一一探秘这些用法。
kafka是一个消息队列产品，基于Topic partitions的设计，能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka，封装了Apache 的Kafka-client，用于在Spring项目里快速集成kafka。除了简单的收发消息外，Spring-kafka还提供了很多高级功能，下面我们就来一一探秘这些用法。
kafka是一个消息队列产品，基于Topic partitions的设计，能达到非常高的消息发送处理性能。Spring创建了一个项目Spring-kafka，封装了Apache 的Kafka-client，用于在Spring项目里快速集成kafka。
答：多年来，随着新功能的增加，spring变得越来越复杂。只需访问页面https://spring.io/projects，我们将看到所有在应用程序中使用的不同功能的spring项目。如果必须启动一个新的spring项目，我们必须添加构建路径或maven依赖项，配置application server，添加spring配置。因此，启动一个新的spring项目需要大量的工作，因为我们目前必须从头开始做所有事情。Spring Boot是这个问题的解决方案。Spring boot构建在现有Spring框架之上。使用spring boot，我们可以避免以前必须执行的所有样板代码和配置。因此，Spring boot帮助我们更健壮地使用现有的Spring功能，并且只需最少的工作量。
Spring Boot 3.0 现已正式发布，它包含了 12 个月以来 151 个开发者的 5700 多次代码提交。这是自 4.5 年前发布 2.0 以来，Spring Boot 的第一次重大修订。
启动服务: systemctl start nansha重启服务systemctl restart nansha查看该服务的状态:systemctl status nansha停止服务并从自启动项中删除
对于事件流应用程序开发人员，根据管道中各个应用程序的更改需要不断更新流管道非常重要。理解流开发人员用于构建事件流管道的一些常见流拓扑也很重要。
Swagger广泛用于可视化API，使用Swagger UI为前端开发人员提供在线沙箱。Swagger是用于生成RESTful Web服务的可视化表示的工具，规范和完整框架实现。
GraalVM 是一种高性能的虚拟机，它可以显著的提高程序的性能和运行效率，非常适合微服务。最近比较火的 Java 框架 Quarkus 默认支持 GraalVM
上周（2019年10月16日）Spring Boot 2.2已经正式发布了!在此篇文章中，将给大家介绍一下2.2版为大家带来了哪些重要的新变化。笔者用心书写，希望阅读完成之后转发关注，你的支持是我不竭的创作动力！
云原生时代的微服务又有什么特点?当前有哪些比较活跃的微服务项目?阿里巴巴资深技术专家李响从微服务的生命周期、流量治理、编程模型以及可信安全4个方面，分享他对微服务与云原生之间的关系的理解。 云原生时代
如果你问研发同学，在开发过程中最讨厌、最痛苦的事情是什么？大部分同学会告诉环境，环境，还是环境。
先简单介绍下我们的使用场景，线上5台Broker节点的kafka承接了所有binlog订阅的数据，用于Flink组件接收数据做数据中台的原始数据。昨儿开发反馈，线上的binlog大量报错，都是kafka的异常，而且都是同一条topic抛的错，特征也很明显，发送的消息体非常大，主观判断肯定是写入大消息导致的超时了，异常详情如下：
Spring Boot3.0.1-SNAPSHOT下依赖组件的版本要求也不尽相同，比如Spring Boot Kafka Starter可能对Kafka有什么要求，这要求你进行充分评估。Spring Cloud体系应该在对应的Spring Boot 3.0.1-SNAPSHOT体系发布后进行升级。
分布式环境下的统一配置框架，已经有不少了，比如百度的disconf，阿里的diamand。今天来看下spring cloud对应的解决方案： 如上图，从架构上就可以看出与disconf之类的有很大不
GraalVM[1] 是一种高性能的虚拟机，它可以显著的提高程序的性能和运行效率，非常适合微服务。最近比较火的 Java 框架 Quarkus[2] 默认支持 GraalVM
写作本文的背景是由于字节的暑期青训营中，某个项目要求编写一个简易的流处理引擎（flink），开发语言不限，推荐Java，本着好奇心的驱使，我打算使用Go语言进行部分尝试。
Spring Cloud Task支持使用消息队列来启动任务。使用消息队列启动任务使我们能够实现异步任务执行，从而进一步提高任务的可用性和灵活性。
程序员，立之根本还是技术，一个程序员的好坏，虽然不能完全用技术强弱来判断，但是技术水平一定是基础，技术差的程序员只能CRUD，技术不深的程序员也成不了架构师。程序员对于技术的掌握，除了从了解-熟悉-熟练-精通的过程以外，还应该从基础出发，到进阶，到源码，到实战。所以，程序员想要成功，首先要成就自己。
要注意source的使用; 在root下使用之后有时需要在hadoop用户下再source一次才可以；
使用Spring Cloud Stream 1.3.2.RELEASE向Kafka发布String消息。 当使用命令行Kafka使用者或Spring Kafka @KafkaListener使用消息时，contentType标头始终附加到消息正文
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
