当前位置:网站首页>Idea view bytecode configuration
Idea view bytecode configuration
2022-07-02 09:25:00 【niceyz】
File-Settings-Tool-External Tools
show byte code
$JDKPath$\bin\javap.exe
-c $FileClass$
$OutputPath$
/********************** kafka **********************/
Kafka cluster colony
Point to point mode , Thread monitoring is required
Release / subscribe , The push speed is inconsistent with the client speed
Save the message according to topic categorize .
sender producer
The recipient consumer
Multiple instances , Each instance (server) be called broker
kafka rely on zookeeper Cluster save meta Information , Ensure system availability . Client requests can only Leader Handle
partition: Partition
Kafka Cluster colony :
Broker1 :
TopcicA(partition0) Leader
TopcicA(partition1) Follower
Broker2 :
TopcicA(partition0) Follower
TopcicA(partition1) Leader
Broker3 :
Partition0(message0、message1) topic It's divided into one area
Follower Do nothing
Consumer groups cannot consume the same partition at the same time
ConsumerA
Consumer group
ConsumerB
One consumer can consume more than one topic
mkdir logs
cd config
Set up the cluster , modify : server.properties
broker.id=0
delete.topic.enable=true
log.dirs=/opt/module
zookeeper.connect=hadoop102:2181,hadoop103:2181,hadoop104:2181
cd ..
xsync kafka/
vi server.properties
broker.id=1
broker.id=2
start-up kafka Start before Zookeeper:
zkstart.sh
Check whether the startup is successful :
/opt/module/zookeeper-3.4.10/bin/zkServer.sh status
Mode:follower Indicating successful startup .
start-up kafka:
machine 1:bin/kafka-server-start.sh config/server/properties
machine 2:bin/kafka-server-start.sh config/server/properties
machine 3:bin/kafka-server-start.sh config/server/properties
Each machine needs to be started separately
util.sh Check the startup process of three machines
establish Partition number 2 individual replications 2 individual topic name
bin/kafka-topics.sh --create --zookeeper hadoop102:2181 --partitions 2 -- replication-factor 2 --topic first
see
bin/kafka-topics.sh --list --zookeeper hadoop102:2181
Check the log
cd logs
Three machines , Number of copies set 5, Will report a mistake , Prompt for up to copies 3.
establish Partition 2 copy 5 topic name
bin/kafka-topics.sh --create --zookeeper hadoop102:2181 --partitions 2 -- replication-factor 5 --topic second
Start producer : To which topic send out
bin/kafka-console-producer.sh --broker -list hadoop102:9092 --topic first
>hello
>yz
Start consumer ( colony ) stay 103 Machine start up
Which one to consume topic, Get the latest data Consume from the beginning
bin/kafka-console-consumer.sh --zookeeper hadoop102:2181 --topic first --from-beginning
Use bootstrap-server Instead of zookeeper To eliminate the warning
Which one to consume topic, Get the latest data Consume from the beginning
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:2181 --topic first --from-beginning
Data exists topic, Using machines 104 See how many topic
bin/kafka-topics.sh --list --zookeeper hadoop102:2181
__consumer_offsets explain : The system automatically creates , This should be used bootstrap after , Save to local topic
first
see topic details Description specifies topic
bin/kafka-topics.sh --zookeeper hadoop102:2181 --describeopic first
Partition Leader machine copy For election
Topic:first Partition: 0 Leader: 0 Replicas: 0,2 Isr: 0,2
Topic:first Partition: 1 Leader: 1 Replicas: 1,0 Isr: 1,0
Isr: 0,2( These two copies and leader Closest , Forward row ,leader After hanging up , Take the next one instead Leader)
machine whether Leader,Leader Only responsible for the producer to write data ,Follower Initiative from Leader Pull data .
0 Leader
1 Follower
2 Follower
Delete topic, You will be prompted to set to true
bin/kafka-topics.sh --delete --zookeeper hadoop102:2181 -topic first
Create from New topic
Partition 1 individual copy 3 individual Appoint topic name
bin/kafka-topics.sh --create --zookeeper hadoop102:2181 --partitions 1 --replication-factro 3 --topic first
边栏推荐
- [staff] the lines and spaces of the staff (the nth line and the nth space in the staff | the plus N line and the plus N space on the staff | the plus N line and the plus N space below the staff | the
- How to realize asynchronous programming in a synchronous way?
- Machine learning practice: is Mermaid a love movie or an action movie? KNN announces the answer
- [go practical basis] how to bind and use URL parameters in gin
- Programmers with ten years of development experience tell you, what core competitiveness do you lack?
- I've taken it. MySQL table 500W rows, but someone doesn't partition it?
- 西瓜书--第五章.神经网络
- Elastic Stack之Beats(Filebeat、Metricbeat)、Kibana、Logstash教程
- Amq6126 problem solving ideas
- Chrome browser tag management plug-in – onetab
猜你喜欢
What is the future value of fluorite mine of karaqin Xinbao Mining Co., Ltd. under zhongang mining?
Statistical learning methods - Chapter 5, decision tree model and learning (Part 1)
C language - Blue Bridge Cup - 7 segment code
Chrome浏览器标签管理插件–OneTab
Chrome用户脚本管理器-Tampermonkey 油猴
Chrome视频下载插件–Video Downloader for Chrome
我服了,MySQL表500W行,居然有人不做分区?
Cloud computing in my eyes - PAAS (platform as a service)
【Go实战基础】gin 如何绑定与使用 url 参数
win10使用docker拉取redis镜像报错read-only file system: unknown
随机推荐
Redis sorted set data type API and application scenario analysis
使用IBM MQ远程连接时报错AMQ 4043解决思路
【Go实战基础】gin 高效神器,如何将参数绑定到结构体
Chrome用户脚本管理器-Tampermonkey 油猴
oracle删除表空间及用户
AMQ 4043 solution for errors when using IBM MQ remote connection
Methods of classfile
Watermelon book -- Chapter 6 Support vector machine (SVM)
Redis zadd导致的一次线上问题排查和处理
Jingdong senior engineer has developed for ten years and compiled "core technology of 100 million traffic website architecture"
《统计学习方法》——第五章、决策树模型与学习(上)
cmd窗口中中文呈现乱码解决方法
【Go实战基础】gin 如何设置路由
Data type case of machine learning -- using data to distinguish men and women based on Naive Bayesian method
Watermelon book -- Chapter 5 neural network
Matplotlib剑客行——布局指南与多图实现(更新)
[staff] time mark and note duration (staff time mark | full note rest | half note rest | quarter note rest | eighth note rest | sixteenth note rest | thirty second note rest)
MySql报错:unblock with mysqladmin flush-hosts
[go practical basis] how to customize and use a middleware in gin
WSL安装、美化、网络代理和远程开发