"This is the 15th day of my participation in the November Text Challenge. For details: 2021 Last Text Challenge" Architecture case Kafka Cluster: Consists of...
SpringBoot kafka 1. Kafka 2 has been installed. Create a SpringBoot project Add project dependencies Add the configuration file application.properties Add the configuration file (optional)...
In the publish-subscribe model, a message is broadcast to all consumers and can be processed by any consumer that receives it. Kafka provides a single...
Some services in the project need to monitor the startup information of other micro-services, and the master needs to send requests to pull some configurations...
This article mainly analyzes a kafka consumer offset lag that keeps increasing. See abnormal log at the beginning, to find this, plus the above jstack,...
This series of articles will focus on Pulsar and Kafka's latencies, followed by articles on throughput. This article covers the test details, the next article...
At present, the underlying computing platform based on Hadoop technology stack is more stable and mature, and computing capacity is no longer the main bottleneck....
Let's look directly at NetworkClient's poll() method: Let's look at handling timeout requests handleTimedOutRequests(Responses, updatedNow) that is, quests that have not been received for a...
There are many articles explaining the principle of Spark Streaming, which will not be covered here. This article mainly introduces the programming model using Kafka...
The previous article is an offline data analysis case based on MapReduce, which processes the user access logs generated by the website and analyzes the...
Kafka is a distributed publish-subscribe messaging system. It was originally developed by LinkedIn and later became part of the Apache project. Kafka is a distributed,...
Spark Streaming is an extension of the Spark Core API that can be used for large-scale, high-throughput, fault-tolerant real-time data Streaming. It supports reading data...
Cloud + Introduction: On April 22, The Tencent Cloud + Community technology salon Kafka Meetup shenzhen station hosted by Tencent Cloud and Kafka community and...
Kafka version: 0.9.0 in front of the author wrote an article on the clean sticky packet unpacking comprehensive explain TCP sticky packet unpacking related problems....
Kafka suffers from message loss. Message loss occurs between brokers, producers, and consumers. Brokerbrokers lose messages due to Kafka itself, Kafka for better performance and...
Similar we write a blocker ProducerInterceptorAnalysis2 again. The purpose of both interceptors is to prefix them before sending, obviously in order A > B and...
Middleware is a type of computer software that connects software components to applications and includes a set of services. To make it easier for multiple...
No nonsense, pure dry goods, SpringBoot integrated Kafka tutorial. The first is the local kafka installation and running, and then springBoot on kafka configuration, including...