银河麒麟高级服务器操作系统V10 SP3安装kafka_2.12-2.3.1
<h1 class="postTitle"><span>银河麒麟高级服务器操作系统V10 SP3安装kafka_2.12-2.3.1</span></h1><div class="clear"> </div>
<div class="postBody">
<div id="cnblogs_post_body" class="blogpost-body blogpost-body-html">
<p>1.安装环境设置</p>
<h4>1关闭Selinux</h4>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_503836" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
<div class="line number18 index17 alt1">18</div>
<div class="line number19 index18 alt2">19</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># vim /etc/selinux/config</code></div>
<div class="line number2 index1 alt1"> </div>
<div class="line number3 index2 alt2"><code class="sql plain"># This file controls the state </code><code class="sql keyword">of</code> <code class="sql plain">SELinux </code><code class="sql keyword">on</code> <code class="sql plain">the system.</code></div>
<div class="line number4 index3 alt1"><code class="sql plain"># SELINUX= can take one </code><code class="sql keyword">of</code> <code class="sql plain">these three </code><code class="sql keyword">values</code><code class="sql plain">:</code></div>
<div class="line number5 index4 alt2"><code class="sql plain"># enforcing - SELinux security policy </code><code class="sql keyword">is</code> <code class="sql plain">enforced.</code></div>
<div class="line number6 index5 alt1"><code class="sql plain"># permissive - SELinux prints warnings </code><code class="sql keyword">instead</code> <code class="sql keyword">of</code> <code class="sql plain">enforcing.</code></div>
<div class="line number7 index6 alt2"><code class="sql plain"># disabled - </code><code class="sql keyword">No</code> <code class="sql plain">SELinux policy </code><code class="sql keyword">is</code> <code class="sql plain">loaded.</code></div>
<div class="line number8 index7 alt1"><code class="sql plain">SELINUX=disabled</code></div>
<div class="line number9 index8 alt2"><code class="sql plain">#SELINUX=enforcing</code></div>
<div class="line number10 index9 alt1"><code class="sql plain"># SELINUXTYPE= can take one </code><code class="sql keyword">of</code> <code class="sql plain">these three </code><code class="sql keyword">values</code><code class="sql plain">:</code></div>
<div class="line number11 index10 alt2"><code class="sql plain"># targeted - Targeted processes are protected,</code></div>
<div class="line number12 index11 alt1"><code class="sql plain"># minimum - Modification </code><code class="sql keyword">of</code> <code class="sql plain">targeted policy. </code><code class="sql keyword">Only</code> <code class="sql plain">selected processes are protected.</code></div>
<div class="line number13 index12 alt2"><code class="sql plain"># ukmls - Multi </code><code class="sql keyword">Level</code> <code class="sql plain">Security protection.</code></div>
<div class="line number14 index13 alt1"><code class="sql plain"># ukmcs -ukmcs variants </code><code class="sql keyword">of</code> <code class="sql plain">the SELinux policy.</code></div>
<div class="line number15 index14 alt2"><code class="sql plain">#SELINUXTYPE=targeted</code></div>
<div class="line number16 index15 alt1"><code class="sql plain">SELINUXTYPE=targeted</code></div>
<div class="line number17 index16 alt2"> </div>
<div class="line number18 index17 alt1"><code class="sql plain"># SETLOCALDEFS= </code><code class="sql keyword">Check</code> <code class="sql keyword">local</code> <code class="sql plain">definition changes</code></div>
<div class="line number19 index18 alt2"><code class="sql plain">SETLOCALDEFS=0</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p> 将selinux配置文件中的“SELINUX=enforcing”更改为“SELINUX=disabled”并注释“#SELINUXTYPE=ukmcs”</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_263254" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># setenforce 0 #使配置立即生效</code></div>
<div class="line number2 index1 alt1"><code class="sql plain">setenforce: SELinux </code><code class="sql keyword">is</code> <code class="sql plain">disabled</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<h4>1.2打开防火墙9092端口</h4>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_866299" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># vim /etc/sysconfig/iptables</code></div>
<div class="line number2 index1 alt1"> </div>
<div class="line number3 index2 alt2"><code class="sql plain"># sample configuration </code><code class="sql keyword">for</code> <code class="sql plain">iptables service</code></div>
<div class="line number4 index3 alt1"><code class="sql plain"># you can edit this manually </code><code class="sql color1">or</code> <code class="sql plain">use system-config-firewall</code></div>
<div class="line number5 index4 alt2"><code class="sql plain"># please do </code><code class="sql color1">not</code> <code class="sql plain">ask us </code><code class="sql keyword">to</code> <code class="sql keyword">add</code> <code class="sql plain">additional ports/services </code><code class="sql keyword">to</code> <code class="sql plain">this </code><code class="sql keyword">default</code> <code class="sql plain">configuration</code></div>
<div class="line number6 index5 alt1"><code class="sql plain">*filter</code></div>
<div class="line number7 index6 alt2"><code class="sql plain">:INPUT ACCEPT </code></div>
<div class="line number8 index7 alt1"><code class="sql plain">:</code><code class="sql keyword">FORWARD</code> <code class="sql plain">ACCEPT </code></div>
<div class="line number9 index8 alt2"><code class="sql plain">:</code><code class="sql keyword">OUTPUT</code> <code class="sql plain">ACCEPT </code></div>
<div class="line number10 index9 alt1"><code class="sql plain">-A INPUT -m state </code><code class="sql comments">--state RELATED,ESTABLISHED -j ACCEPT</code></div>
<div class="line number11 index10 alt2"><code class="sql plain">-A INPUT -p icmp -j ACCEPT</code></div>
<div class="line number12 index11 alt1"><code class="sql plain">-A INPUT -i lo -j ACCEPT</code></div>
<div class="line number13 index12 alt2"><code class="sql plain">-A INPUT -p tcp -m state </code><code class="sql comments">--state NEW -m tcp --dport 22 -j ACCEPT</code></div>
<div class="line number14 index13 alt1"><code class="sql plain">-A INPUT -p tcp -m state </code><code class="sql comments">--state NEW -m tcp --dport 9092 -j ACCEPT ##增加9092端口放行规则</code></div>
<div class="line number15 index14 alt2"><code class="sql plain">-A INPUT -j REJECT </code><code class="sql comments">--reject-with icmp-host-prohibited</code></div>
<div class="line number16 index15 alt1"><code class="sql plain">-A </code><code class="sql keyword">FORWARD</code> <code class="sql plain">-j REJECT </code><code class="sql comments">--reject-with icmp-host-prohibited</code></div>
<div class="line number17 index16 alt2"><code class="sql keyword">COMMIT</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_433155" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># systemctl restart iptables #重启防火墙</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<h3>3、安装kafka</h3>
<div class="cnblogs_Highlighter sh-gutter">
<p># find ./libs/ -name *kafka_* | head -1 | grep -o 'kafka[^ ]*' # 查看kafka版本信息<br>kafka_2.11-1.0.0.jar</p>
<p># wget https://archive.apache.org/dist/kafka/1.0.1/kafka_2.11-1.0.1.tgz #下载kafka<br>--2023-02-16 16:12:10-- https://archive.apache.org/dist/kafka/1.0.1/kafka_2.11-1.0.1.tgz<br>正在解析主机 archive.apache.org (archive.apache.org)... 138.201.131.134, 2a01:4f8:172:2ec5::2<br>正在连接 archive.apache.org (archive.apache.org)|138.201.131.134|:443... 已连接。<br>已发出 HTTP 请求，正在等待回应... 200 OK<br>长度：49766096 (47M) <br>正在保存至: “kafka_2.11-1.0.1.tgz”</p>
<p>kafka_2.11-1.0.1.tgz 100%[===============================>] 47.46M 18.8KB/s 用时 60m 58s</p>
<p>2023-02-16 17:13:11 (13.3 KB/s) - 已保存 “kafka_2.11-1.0.1.tgz” [49766096/49766096</p>
<div>
<div id="highlighter_747503" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"><br># tar -zxvf kafka_2.11-1.0.1.tgz</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
<p> # mv kafka_2.11-1.0.1 /opt/kafka</p>
<p># cd /opt/kafka</p>
<p># mkdir -p kafka_data/zookeeper # zookeeper数据<br># mkdir -p kafka_data/log/zookeeper<br># mkdir -p kafka_data/log/kafka # kafka日志 # zookeeper日志</p>
<p>在kafka解压目录同一路径下：创建一个kafka_data，用于装kafka和zookeeper的log和数据。</p>
</div>
<p> </p>
<div class="cnblogs_Highlighter sh-gutter">
<p># cd /opt/kafka<br># ll<br>总用量 48<br>drwxr-xr-x 3 root root 4096 10月 28 2017 bin<br>drwxr-xr-x 2 root root 4096 10月 28 2017 config<br>drwxr-xr-x 2 root root 4096 2月 20 17:09 libs<br>-rw-r--r-- 1 root root 28824 10月 27 2017 LICENSE<br>-rw-r--r-- 1 root root 336 10月 27 2017 NOTICE<br>drwxr-xr-x 2 root root 44 10月 28 2017 site-docs</p>
<div>
<div id="highlighter_153745" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
<div class="line number18 index17 alt1">18</div>
<div class="line number19 index18 alt2">19</div>
<div class="line number20 index19 alt1">20</div>
<div class="line number21 index20 alt2">21</div>
<div class="line number22 index21 alt1">22</div>
<div class="line number23 index22 alt2">23</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"><br># cd config</code></div>
<div class="line number2 index1 alt1"><code class="sql plain"># ll</code></div>
<div class="line number3 index2 alt2"><code class="sql plain">总用量 64</code></div>
<div class="line number4 index3 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 906 10月 27 2017 connect-console-sink.properties</code></div>
<div class="line number5 index4 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 909 10月 27 2017 connect-console-source.properties</code></div>
<div class="line number6 index5 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 5807 10月 27 2017 connect-distributed.properties</code></div>
<div class="line number7 index6 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 883 10月 27 2017 connect-file-sink.properties</code></div>
<div class="line number8 index7 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 881 10月 27 2017 connect-file-source.properties</code></div>
<div class="line number9 index8 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 1111 10月 27 2017 connect-log4j.properties</code></div>
<div class="line number10 index9 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 2730 10月 27 2017 connect-standalone.properties</code></div>
<div class="line number11 index10 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 1221 10月 27 2017 consumer.properties</code></div>
<div class="line number12 index11 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 4727 10月 27 2017 log4j.properties</code></div>
<div class="line number13 index12 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 1919 10月 27 2017 producer.properties</code></div>
<div class="line number14 index13 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 6852 10月 27 2017 server.properties</code></div>
<div class="line number15 index14 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 1032 10月 27 2017 tools-log4j.properties</code></div>
<div class="line number16 index15 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 1023 10月 27 2017 zookeeper.properties</code></div>
<div class="line number17 index16 alt2"><code class="sql plain"># sudo cp server.properties server-1.properties</code></div>
<div class="line number18 index17 alt1"><code class="sql plain"># sudo cp server.properties server-2.properties</code></div>
<div class="line number19 index18 alt2"><code class="sql plain"># sudo chmod -R 777 /opt/kafka</code></div>
<div class="line number20 index19 alt1"><code class="sql plain"># cd /opt/kafka/bin</code></div>
<div class="line number21 index20 alt2"><code class="sql plain"># nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &</code></div>
<div class="line number22 index21 alt1"><code class="sql plain"> 13293</code></div>
<div class="line number23 index22 alt2"><code class="sql plain"># nohup: 忽略输入并把输出追加到</code><code class="sql string">'nohup.out'</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p> </p>
<h4>3.2配置kafka服务</h4>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_808919" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># cd config</code></div>
<div class="line number2 index1 alt1"><code class="sql plain"># vim server.properties<br><br>编辑修改相应的参数，内容改动和添加如下：</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
<p>broker.id=0<br>port=9092 #端口号<br>host.name=192.168.65.130 #服务器IP地址，修改为自己的服务器IP<br>log.dirs=/data/kafka/kafka_data/log/kafka #日志存放路径，上面创建的目录<br>zookeeper.connect=localhost:2181 #zookeeper地址和端口，单机配置部署，localhost:2181</p>
</div>
<p> </p>
<h4>3.3配置zookeeper服务</h4>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_99289" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
<div class="line number8 index7 alt1">8</div>
<div class="line number9 index8 alt2">9</div>
<div class="line number10 index9 alt1">10</div>
<div class="line number11 index10 alt2">11</div>
<div class="line number12 index11 alt1">12</div>
<div class="line number13 index12 alt2">13</div>
<div class="line number14 index13 alt1">14</div>
<div class="line number15 index14 alt2">15</div>
<div class="line number16 index15 alt1">16</div>
<div class="line number17 index16 alt2">17</div>
<div class="line number18 index17 alt1">18</div>
<div class="line number19 index18 alt2">19</div>
<div class="line number20 index19 alt1">20</div>
<div class="line number21 index20 alt2">21</div>
<div class="line number22 index21 alt1">22</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># cd kafka</code></div>
<div class="line number2 index1 alt1"><code class="sql plain"># ll</code></div>
<div class="line number3 index2 alt2"><code class="sql plain">总用量 56</code></div>
<div class="line number4 index3 alt1"><code class="sql plain">drwxr-xr-x 3 root root 4096 2月 22 2018 bin</code></div>
<div class="line number5 index4 alt2"><code class="sql plain">drwxr-xr-x 2 root root 4096 2月 16 17:33 config</code></div>
<div class="line number6 index5 alt1"><code class="sql plain">drwxr-xr-x 4 root root 4096 2月 16 17:28 kafka_data</code></div>
<div class="line number7 index6 alt2"><code class="sql plain">drwxr-xr-x 2 root root 4096 2月 16 17:14 libs</code></div>
<div class="line number8 index7 alt1"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 28824 2月 22 2018 LICENSE</code></div>
<div class="line number9 index8 alt2"><code class="sql plain">-rw-r</code><code class="sql comments">--r-- 1 root root 336 2月 22 2018 NOTICE</code></div>
<div class="line number10 index9 alt1"><code class="sql plain">drwxr-xr-x 2 root root 4096 2月 22 2018 site-docs</code></div>
<div class="line number11 index10 alt2"><code class="sql plain"># cd config</code></div>
<div class="line number12 index11 alt1"><code class="sql plain">#</code></div>
<div class="line number13 index12 alt2"><code class="sql plain"># vim zookeeper.properties</code></div>
<div class="line number14 index13 alt1"> </div>
<div class="line number15 index14 alt2"><code class="sql plain">编辑修改相应的参数，内容改动和添加如下：</code></div>
<div class="line number16 index15 alt1"><code class="sql plain">dataDir=/data/kafka/kafka_data/zookeeper</code></div>
<div class="line number17 index16 alt2"><code class="sql plain">dataLogDir=/data/kafka/kafka_data/log/zookeeper</code></div>
<div class="line number18 index17 alt1"><code class="sql plain">clientPort=2181</code></div>
<div class="line number19 index18 alt2"><code class="sql plain">maxClientCnxns=100</code></div>
<div class="line number20 index19 alt1"><code class="sql plain">tickTime=2000</code></div>
<div class="line number21 index20 alt2"><code class="sql plain">initLimit=10</code></div>
<div class="line number22 index21 alt1"><code class="sql plain">syncLimit=5</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p> </p>
<h4>3.4启动停止服务</h4>
<p>编辑kafka启动脚本</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_353480" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
<div class="line number6 index5 alt1">6</div>
<div class="line number7 index6 alt2">7</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain"># vim kafka_start.sh</code></div>
<div class="line number2 index1 alt1"> </div>
<div class="line number3 index2 alt2"><code class="sql plain">写入以下内容</code></div>
<div class="line number4 index3 alt1"><code class="sql plain">#!/bin/sh</code></div>
<div class="line number5 index4 alt2"><code class="sql plain">/data/kafka/bin/zookeeper-server-start.sh /data/kafka/config/zookeeper.properties &</code></div>
<div class="line number6 index5 alt1"><code class="sql plain">sleep 3</code></div>
<div class="line number7 index6 alt2"><code class="sql plain">/data/kafka/bin/kafka-server-start.sh /data/kafka/config/server.properties &</code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p> 编辑kafka停止脚本# vim kafka_stop.sh</p>
<div class="cnblogs_Highlighter sh-gutter">
<div>
<div id="highlighter_627029" class="syntaxhighlightersql">
<table border="0" cellspacing="0" cellpadding="0">
<tbody>
<tr>
<td class="gutter">
<div class="line number1 index0 alt2">1</div>
<div class="line number2 index1 alt1">2</div>
<div class="line number3 index2 alt2">3</div>
<div class="line number4 index3 alt1">4</div>
<div class="line number5 index4 alt2">5</div>
</td>
<td class="code">
<div class="container">
<div class="line number1 index0 alt2"><code class="sql plain">写入以下内容</code></div>
<div class="line number2 index1 alt1"><code class="sql plain">#!/bin/sh</code></div>
<div class="line number3 index2 alt2"><code class="sql plain">/data/kafka/bin/zookeeper-server-stop.sh /data/kafka/config/zookeeper.properties &</code></div>
<div class="line number4 index3 alt1"><code class="sql plain">sleep 3</code></div>
<div class="line number5 index4 alt2"><code class="sql plain">/data/kafka/bin/kafka-server-stop.sh /data/kafka/config/server.properties &<br></code></div>
</div>
</td>
</tr>
</tbody>
</table>
</div>
</div>
</div>
<p> 为启动、停止脚本赋执行权限</p>
<p># chmod +x kafka_start.sh kafka_stop.sh</p>
<h3>4.kafka测试</h3>
<p>创建生产者 topic 和 消费者 topic 简单示例</p>
<h4><em id="__mceDel">4.1 在一个终端执行创建生产者： (推消息到cqld_test)</em></h4>
</div>
</div><br><br>
来源：https://www.cnblogs.com/yaoyangding/p/17339959.html
頁:
[1]