FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
JavaCoding/shell/batchCreateKafkaTopic at main · SpartaHao/JavaCoding · GitHub
SpartaHao
/
JavaCoding
Public
Notifications
You must be signed in to change notification settings
Fork
0
Star
0
Code
Issues
0
Pull requests
0
Actions
Projects
Security and quality
0
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights
Expand file tree
Breadcrumbs
JavaCoding
/
shell
/
batchCreateKafkaTopic
Copy path
More file actions
More file actions
Latest commit
History
History
History
12 lines (10 loc) · 376 Bytes
Breadcrumbs
JavaCoding
/
shell
/
batchCreateKafkaTopic
Copy path
File metadata and controls
12 lines (10 loc) · 376 Bytes
Raw
Copy raw file
Download raw file
Open symbols panel
Edit and raw actions
1
2
3
4
5
6
7
8
9
10
11
12
#!
/bin/bash
#
批量创建kafka topic
base_dir=
"
/**
"
kafka_dir=
"
/**/kafka_2.11/bin
"
for
line
in
`
cat
$base_dir
/topics.txt
`
do
sh
$kafka_dir
/kafka-topics.sh --create --zookeeper
**
:12181,1
**
:12181,
**
:12181 --replication-factor 3 --partitions 2 --topic
${line}
done
echo
"
topic列表如下:
"
sh
$base_dir
/kafka-topics.sh --zookeeper
**
:12181 --list
Back
|
FazBrowse Home
|
New Git URL