In the class, we introduced the basic concepts of Kafka, including the composition of message, topic, partition, broker and the relationship between them
Flowers angry horse youth, whip spring breeze hunting prosperous. Strong spirit is not brave, especially read Chang 'an April flower. I hope I will stay...
Let's start with the sample code and trace the source code through the corresponding parameters in the code. Kafka sends messages via KafkaProducer. Send. The...
Kafka is an open source, lightweight, multi-partition, multi-copy, distributed message flow platform based on Zookeeper. Compared with other messaging systems, it has the following advantages...
1.1 When an Acceptor is started on a server, the SocketServer is initialized. The Acceptor and Processor threads are initialized to process connection requests. This...
Kafkacat is a non-JVM command line producer and consumer that can quickly produce and consume Kafka messages. Note: If you want to copy the Kafkacat...
In the last section, we set up a Kafka cluster. However, Kafka clusters generate all kinds of data, such as broker information, cluster information, topic...
Audit logging systems are useful for much more than storing data for audit purposes. In addition to compliance and security purposes, it can be used...
Today, let's talk about kafka, a popular message queue component in the big data scenario. This article will mainly be introduced from a theoretical perspective....
This article mainly summarizes what capabilities we need to ensure high availability, high reliability, high performance, high throughput, and safe operation of Kafka clusters when...
This article first introduces what Kafka is, and kafka's advantages, daily use scenarios, as well as some basic concepts of Kafka, these are the most...
Kafka can build streaming data pipes that reliably fetch data between systems or applications. Build streaming application transmission and response data. In large systems, where...
What are synchronous IO and asynchronous IO, blocking IO and non-blocking IO, and what are the differences? Different people give different answers in different contexts....
Message queue uses scenario queue, which is a first-in, first-out structure in data structure. Message queue can be regarded as a container holding messages, which...
This exception is also a common exception in our development, we need to pay attention to this exception, otherwise it will cause your business message...
Solutions of the coupling. Asynchronous processing such as e-commerce platforms, seckilling activities. The general process can be divided into: 1: risk control, 2: inventory lock,...
For more big data learning articles or summaries, you can search cicada Alley on wechat, pay attention to the public number and reply to information...