devbox
我家小花儿
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Kafka学习笔记——centos7下kafka安装配置与验证_centos kafka advertised.host.name

作者：我家小花儿 | 2024-08-15 10:48:50

赞

踩

centos kafka advertised.host.name

简介

我们先看看官方给出的kafka分布式架构图 
这里写图片描述 
多个 broker 协同合作，producer 和 consumer 部署在各个业务逡辑中被频繁的调用，三者通过 zookeeper管理协调请求和转収。返样一个高怅能的分布式消息収布不订阅系统就完成了。 
我们以一个broker为例介绍下整个消息系统的启动过程 
这里写图片描述 
整个系统运行的顺序： 
1.启劢 zookeeper 的 server 
2.启劢 kafka 的 server 
3.Producer 如果生产了数据，会先通过 zookeeper 找刡 broker，然后将数据存放迕 broker 
4.Consumer 如果要消费数据，会先通过 zookeeper 找对应的 broker，然后消费。

分布式环境搭建

单机版

先去kafka官网现在最新的kafka安装包

[root@bogon software]# wget http://apache.fayea.com/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz
 
 
  • 1

这里写图片描述 
然后把kafka解压到安装目录下

[root@bogon software]# tar -zvxf kafka_2.10-0.10.2.1.tgz -C /usr/local/kafka/
 
 
  • 1

这里写图片描述 
重命名kafka安装包，方便配置

[root@bogon kafka]# mv kafka_2.10-0.10.2.1 kafk
 
 
  • 1

进入kafka/bin文件夹，这里有各种功能脚本，包括发送消息，消费消息、创建topic，查看topic以及各种启动、停止服务脚本等 
这里写图片描述 
启动zookeeper

[root@bogon bin]# sh zookeeper-server-start.sh -daemon ../config/zookeeper.properties
 
 
  • 1

这里写图片描述 
启动kafka服务

[root@bogon bin]# sh kafka-server-start.sh ../config/server.properties
 
 
  • 1

提示如下错误： 
这里写图片描述 
这时候我们需要修改下主机名

  1. [root@xg sysconfig]# hostname localhost
  2. [root@xg sysconfig]# su

 
 
  • 1
  • 2

这里写图片描述 
再次执行

[root@localhost bin]# sh kafka-server-start.sh ../config/server.properties
 
 
  • 1
  1. [root@localhost bin]# sh kafka-server-start.sh ../config/server.properties 
  2. [2017-06-16 20:49:10,581] INFO KafkaConfig values: 
  3.         advertised.host.name = null
  4.         advertised.listeners = null
  5.         advertised.port = null
  6.         authorizer.class.name = 
  7.         auto.create.topics.enable = true
  8.         auto.leader.rebalance.enable = true
  9.         background.threads = 10
  10.         broker.id = 0
  11.         broker.id.generation.enable = true
  12.         broker.rack = null
  13.         compression.type = producer
  14.         connections.max.idle.ms = 600000
  15.         controlled.shutdown.enable = true
  16.         controlled.shutdown.max.retries = 3
  17.         controlled.shutdown.retry.backoff.ms = 5000
  18.         controller.socket.timeout.ms = 30000
  19.         create.topic.policy.class.name = null
  20.         default.replication.factor = 1
  21.         delete.topic.enable = false
  22.         fetch.purgatory.purge.interval.requests = 1000
  23.         group.max.session.timeout.ms = 300000
  24.         group.min.session.timeout.ms = 6000
  25.         host.name = 
  26.         inter.broker.listener.name = null
  27.         inter.broker.protocol.version = 0.10.2-IV0
  28.         leader.imbalance.check.interval.seconds = 300
  29.         leader.imbalance.per.broker.percentage = 10
  30.         listener.security.protocol.map = SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,TRACE:TRACE,SASL_SSL:SASL_SSL,PLAINTEXT:PLAINTEXT
  31.         listeners = null
  32.         log.cleaner.backoff.ms = 15000
  33.         log.cleaner.dedupe.buffer.size = 134217728
  34.         log.cleaner.delete.retention.ms = 86400000
  35.         log.cleaner.enable = true
  36.         log.cleaner.io.buffer.load.factor = 0.9
  37.         log.cleaner.io.buffer.size = 524288
  38.         log.cleaner.io.max.bytes.per.second = 1.7976931348623157E308
  39.         log.cleaner.min.cleanable.ratio = 0.5
  40.         log.cleaner.min.compaction.lag.ms = 0
  41.         log.cleaner.threads = 1
  42.         log.cleanup.policy = [delete]
  43.         log.dir = /tmp/kafka-logs
  44.         log.dirs = /tmp/kafka-logs
  45.         log.flush.interval.messages = 9223372036854775807
  46.         log.flush.interval.ms = null
  47.         log.flush.offset.checkpoint.interval.ms = 60000
  48.         log.flush.scheduler.interval.ms = 9223372036854775807
  49.         log.index.interval.bytes = 4096
  50.         log.index.size.max.bytes = 10485760
  51.         log.message.format.version = 0.10.2-IV0
  52.         log.message.timestamp.difference.max.ms = 9223372036854775807
  53.         log.message.timestamp.type = CreateTime
  54.         log.preallocate = false
  55.         log.retention.bytes = -1
  56.         log.retention.check.interval.ms = 300000
  57.         log.retention.hours = 168
  58.         log.retention.minutes = null
  59.         log.retention.ms = null
  60.         log.roll.hours = 168
  61.         log.roll.jitter.hours = 0
  62.         log.roll.jitter.ms = null
  63.         log.roll.ms = null
  64.         log.segment.bytes = 1073741824
  65.         log.segment.delete.delay.ms = 60000
  66.         max.connections.per.ip = 2147483647
  67.         max.connections.per.ip.overrides = 
  68.         message.max.bytes = 1000012
  69.         metric.reporters = []
  70.         metrics.num.samples = 2
  71.         metrics.recording.level = INFO
  72.         metrics.sample.window.ms = 30000
  73.         min.insync.replicas = 1
  74.         num.io.threads = 8
  75.         num.network.threads = 3
  76.         num.partitions = 1
  77.         num.recovery.threads.per.data.dir = 1
  78.         num.replica.fetchers = 1
  79.         offset.metadata.max.bytes = 4096
  80.         offsets.commit.required.acks = -1
  81.         offsets.commit.timeout.ms = 5000
  82.         offsets.load.buffer.size = 5242880
  83.         offsets.retention.check.interval.ms = 600000
  84.         offsets.retention.minutes = 1440
  85.         offsets.topic.compression.codec = 0
  86.         offsets.topic.num.partitions = 50
  87.         offsets.topic.replication.factor = 3
  88.         offsets.topic.segment.bytes = 104857600
  89.         port = 9092
  90.         principal.builder.class = class org.apache.kafka.common.security.auth.DefaultPrincipalBuilder
  91.         producer.purgatory.purge.interval.requests = 1000
  92.         queued.max.requests = 500
  93.         quota.consumer.default = 9223372036854775807
  94.         quota.producer.default = 9223372036854775807
  95.         quota.window.num = 11
  96.         quota.window.size.seconds = 1
  97.         replica.fetch.backoff.ms = 1000
  98.         replica.fetch.max.bytes = 1048576
  99.         replica.fetch.min.bytes = 1
  100.         replica.fetch.response.max.bytes = 10485760
  101.         replica.fetch.wait.max.ms = 500
  102.         replica.high.watermark.checkpoint.interval.ms = 5000
  103.         replica.lag.time.max.ms = 10000
  104.         replica.socket.receive.buffer.bytes = 65536
  105.         replica.socket.timeout.ms = 30000
  106.         replication.quota.window.num = 11
  107.         replication.quota.window.size.seconds = 1
  108.         request.timeout.ms = 30000
  109.         reserved.broker.max.id = 1000
  110.         sasl.enabled.mechanisms = [GSSAPI]
  111.         sasl.kerberos.kinit.cmd = /usr/bin/kinit
  112.         sasl.kerberos.min.time.before.relogin = 60000
  113.         sasl.kerberos.principal.to.local.rules = [DEFAULT]
  114.         sasl.kerberos.service.name = null
  115.         sasl.kerberos.ticket.renew.jitter = 0.05
  116.         sasl.kerberos.ticket.renew.window.factor = 0.8
  117.         sasl.mechanism.inter.broker.protocol = GSSAPI
  118.         security.inter.broker.protocol = PLAINTEXT
  119.         socket.receive.buffer.bytes = 102400
  120.         socket.request.max.bytes = 104857600
  121.         socket.send.buffer.bytes = 102400
  122.         ssl.cipher.suites = null
  123.         ssl.client.auth = none
  124.         ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  125.         ssl.endpoint.identification.algorithm = null
  126.         ssl.key.password = null
  127.         ssl.keymanager.algorithm = SunX509
  128.         ssl.keystore.location = null
  129.         ssl.keystore.password = null
  130.         ssl.keystore.type = JKS
  131.         ssl.protocol = TLS
  132.         ssl.provider = null
  133.         ssl.secure.random.implementation = null
  134.         ssl.trustmanager.algorithm = PKIX
  135.         ssl.truststore.location = null
  136.         ssl.truststore.password = null
  137.         ssl.truststore.type = JKS
  138.         unclean.leader.election.enable = true
  139.         zookeeper.connect = localhost:2181
  140.         zookeeper.connection.timeout.ms = 6000
  141.         zookeeper.session.timeout.ms = 6000
  142.         zookeeper.set.acl = false
  143.         zookeeper.sync.time.ms = 2000
  144.  (kafka.server.KafkaConfig)
  145. [2017-06-16 20:49:10,678] INFO starting (kafka.server.KafkaServer)
  146. [2017-06-16 20:49:10,681] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
  147. [2017-06-16 20:49:10,706] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
  148. [2017-06-16 20:49:10,729] INFO Client environment:zookeeper.version=3.4.9-1757313, built on 08/23/2016 06:50 GMT (org.apache.zookeeper.ZooKeeper)
  149. [2017-06-16 20:49:10,729] INFO Client environment:host.name=localhost (org.apache.zookeeper.ZooKeeper)
  150. [2017-06-16 20:49:10,729] INFO Client environment:java.version=1.8.0_101 (org.apache.zookeeper.ZooKeeper)
  151. [2017-06-16 20:49:10,729] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper)
  152. [2017-06-16 20:49:10,729] INFO Client environment:java.home=/usr/local/java/jdk1.8.0_101/jre (org.apache.zookeeper.ZooKeeper)
  153. [2017-06-16 20:49:10,729] INFO Client environment:java.class.path=.:/usr/local/java/jdk1.8.0_101/lib/dt.jar:/usr/local/java/jdk1.8.0_101/lib/tools.jar:/usr/local/kafka/kafka/bin/../libs/aopalliance-repackaged-2.5.0-b05.jar:/usr/local/kafka/kafka/bin/../libs/argparse4j-0.7.0.jar:/usr/local/kafka/kafka/bin/../libs/connect-api-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/connect-file-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/connect-json-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/connect-runtime-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/connect-transforms-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/guava-18.0.jar:/usr/local/kafka/kafka/bin/../libs/hk2-api-2.5.0-b05.jar:/usr/local/kafka/kafka/bin/../libs/hk2-locator-2.5.0-b05.jar:/usr/local/kafka/kafka/bin/../libs/hk2-utils-2.5.0-b05.jar:/usr/local/kafka/kafka/bin/../libs/jackson-annotations-2.8.0.jar:/usr/local/kafka/kafka/bin/../libs/jackson-annotations-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/jackson-core-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/jackson-databind-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/jackson-jaxrs-base-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/jackson-jaxrs-json-provider-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/jackson-module-jaxb-annotations-2.8.5.jar:/usr/local/kafka/kafka/bin/../libs/javassist-3.20.0-GA.jar:/usr/local/kafka/kafka/bin/../libs/javax.annotation-api-1.2.jar:/usr/local/kafka/kafka/bin/../libs/javax.inject-1.jar:/usr/local/kafka/kafka/bin/../libs/javax.inject-2.5.0-b05.jar:/usr/local/kafka/kafka/bin/../libs/javax.servlet-api-3.1.0.jar:/usr/local/kafka/kafka/bin/../libs/javax.ws.rs-api-2.0.1.jar:/usr/local/kafka/kafka/bin/../libs/jersey-client-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-common-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-container-servlet-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-container-servlet-core-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-guava-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-media-jaxb-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jersey-server-2.24.jar:/usr/local/kafka/kafka/bin/../libs/jetty-continuation-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-http-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-io-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-security-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-server-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-servlet-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-servlets-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jetty-util-9.2.15.v20160210.jar:/usr/local/kafka/kafka/bin/../libs/jopt-simple-5.0.3.jar:/usr/local/kafka/kafka/bin/../libs/kafka_2.10-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/kafka_2.10-0.10.2.1-sources.jar:/usr/local/kafka/kafka/bin/../libs/kafka_2.10-0.10.2.1-test-sources.jar:/usr/local/kafka/kafka/bin/../libs/kafka-clients-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/kafka-log4j-appender-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/kafka-streams-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/kafka-streams-examples-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/kafka-tools-0.10.2.1.jar:/usr/local/kafka/kafka/bin/../libs/log4j-1.2.17.jar:/usr/local/kafka/kafka/bin/../libs/lz4-1.3.0.jar:/usr/local/kafka/kafka/bin/../libs/metrics-core-2.2.0.jar:/usr/local/kafka/kafka/bin/../libs/osgi-resource-locator-1.0.1.jar:/usr/local/kafka/kafka/bin/../libs/reflections-0.9.10.jar:/usr/local/kafka/kafka/bin/../libs/rocksdbjni-5.0.1.jar:/usr/local/kafka/kafka/bin/../libs/scala-library-2.10.6.jar:/usr/local/kafka/kafka/bin/../libs/slf4j-api-1.7.21.jar:/usr/local/kafka/kafka/bin/../libs/slf4j-log4j12-1.7.21.jar:/usr/local/kafka/kafka/bin/../libs/snappy-java-1.1.2.6.jar:/usr/local/kafka/kafka/bin/../libs/validation-api-1.1.0.Final.jar:/usr/local/kafka/kafka/bin/../libs/zkclient-0.10.jar:/usr/local/kafka/kafka/bin/../libs/zookeeper-3.4.9.jar (org.apache.zookeeper.ZooKeeper)
  154. [2017-06-16 20:49:10,730] INFO Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib (org.apache.zookeeper.ZooKeeper)
  155. [2017-06-16 20:49:10,730] INFO Client environment:java.io.tmpdir=/tmp (org.apache.zookeeper.ZooKeeper)
  156. [2017-06-16 20:49:10,730] INFO Client environment:java.compiler=<NA> (org.apache.zookeeper.ZooKeeper)
  157. [2017-06-16 20:49:10,730] INFO Client environment:os.name=Linux (org.apache.zookeeper.ZooKeeper)
  158. [2017-06-16 20:49:10,730] INFO Client environment:os.arch=amd64 (org.apache.zookeeper.ZooKeeper)
  159. [2017-06-16 20:49:10,730] INFO Client environment:os.version=3.10.0-327.el7.x86_64 (org.apache.zookeeper.ZooKeeper)
  160. [2017-06-16 20:49:10,730] INFO Client environment:user.name=root (org.apache.zookeeper.ZooKeeper)
  161. [2017-06-16 20:49:10,730] INFO Client environment:user.home=/root (org.apache.zookeeper.ZooKeeper)
  162. [2017-06-16 20:49:10,730] INFO Client environment:user.dir=/usr/local/kafka/kafka/bin (org.apache.zookeeper.ZooKeeper)
  163. [2017-06-16 20:49:10,732] INFO Initiating client connection, connectString=localhost:2181 sessionTimeout=6000 watcher=org.I0Itec.zkclient.ZkClient@21de60b4 (org.apache.zookeeper.ZooKeeper)
  164. [2017-06-16 20:49:10,759] INFO Waiting for keeper state SyncConnected (org.I0Itec.zkclient.ZkClient)
  165. [2017-06-16 20:49:10,766] INFO Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn)
  166. [2017-06-16 20:49:10,903] INFO Socket connection established to localhost/0:0:0:0:0:0:0:1:2181, initiating session (org.apache.zookeeper.ClientCnxn)
  167. [2017-06-16 20:49:10,926] INFO Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2181, sessionid = 0x15cb42456980001, negotiated timeout = 6000 (org.apache.zookeeper.ClientCnxn)
  168. [2017-06-16 20:49:10,931] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
  169. [2017-06-16 20:49:11,200] INFO Cluster ID = qln2xViYSCGEl63misidng (kafka.server.KafkaServer)
  170. [2017-06-16 20:49:11,206] WARN No meta.properties file under dir /tmp/kafka-logs/meta.properties (kafka.server.BrokerMetadataCheckpoint)
  171. [2017-06-16 20:49:11,246] INFO [ThrottledRequestReaper-Fetch], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
  172. [2017-06-16 20:49:11,250] INFO [ThrottledRequestReaper-Produce], Starting  (kafka.server.ClientQuotaManager$ThrottledRequestReaper)
  173. [2017-06-16 20:49:11,314] INFO Loading logs. (kafka.log.LogManager)
  174. [2017-06-16 20:49:11,327] INFO Logs loading complete in 11 ms. (kafka.log.LogManager)
  175. [2017-06-16 20:49:11,436] INFO Starting log cleanup with a period of 300000 ms. (kafka.log.LogManager)
  176. [2017-06-16 20:49:11,439] INFO Starting log flusher with a default period of 9223372036854775807 ms. (kafka.log.LogManager)
  177. [2017-06-16 20:49:11,520] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)
  178. [2017-06-16 20:49:11,526] INFO [Socket Server on Broker 0], Started 1 acceptor threads (kafka.network.SocketServer)
  179. [2017-06-16 20:49:11,560] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  180. [2017-06-16 20:49:11,564] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  181. [2017-06-16 20:49:11,644] INFO Creating /controller (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
  182. [2017-06-16 20:49:11,660] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
  183. [2017-06-16 20:49:11,660] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector)
  184. [2017-06-16 20:49:11,821] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  185. [2017-06-16 20:49:11,842] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  186. [2017-06-16 20:49:11,848] INFO New leader is 0 (kafka.server.ZookeeperLeaderElector$LeaderChangeListener)
  187. [2017-06-16 20:49:11,851] INFO [ExpirationReaper-0], Starting  (kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper)
  188. [2017-06-16 20:49:11,866] INFO [GroupCoordinator 0]: Starting up. (kafka.coordinator.GroupCoordinator)
  189. [2017-06-16 20:49:11,868] INFO [GroupCoordinator 0]: Startup complete. (kafka.coordinator.GroupCoordinator)
  190. [2017-06-16 20:49:11,871] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 2 milliseconds. (kafka.coordinator.GroupMetadataManager)
  191. [2017-06-16 20:49:11,948] INFO Will not load MX4J, mx4j-tools.jar is not in the classpath (kafka.utils.Mx4jLoader$)
  192. [2017-06-16 20:49:12,035] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
  193. [2017-06-16 20:49:12,043] INFO Result of znode creation is: OK (kafka.utils.ZKCheckedEphemeral)
  194. [2017-06-16 20:49:12,046] INFO Registered broker 0 at path /brokers/ids/0 with addresses: EndPoint(localhost,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.utils.ZkUtils)
  195. [2017-06-16 20:49:12,048] WARN No meta.properties file under dir /tmp/kafka-logs/meta.properties (kafka.server.BrokerMetadataCheckpoint)
  196. [2017-06-16 20:49:12,130] INFO Kafka version : 0.10.2.1 (org.apache.kafka.common.utils.AppInfoParser)
  197. [2017-06-16 20:49:12,130] INFO Kafka commitId : e89bffd6b2eff799 (org.apache.kafka.common.utils.AppInfoParser)
  198. [2017-06-16 20:49:12,132] INFO [Kafka Server 0], started (kafka.server.KafkaServer)

 
 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
  • 197
  • 198

最后看到kafka成功启动 
这里写图片描述 
测试 
创建一个topic

  1. [root@localhost bin]# sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic sunwukong
  2. Created topic "sunwukong".

 
 
  • 1
  • 2

topic创建成功，下面我查看一下

  1. [root@localhost bin]# sh kafka-topics.sh --list --zookeeper localhost:2181 
  2. sunwukong

 
 
  • 1
  • 2

发送消息

  1. [root@localhost bin]# sh kafka-console-producer.sh --broker-list localhost:9092 --topic sunwukong
  2. hello sunwukong,haha
  3. this is a test message

 
 
  • 1
  • 2
  • 3

客户端接收消息

  1. [root@localhost bin]# sh kafka-console-consumer.sh --zookeeper localhost:2181 --topic sunwukong --from-beginning
  2. Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major release. Consider using the new consumer by passing [bootstrap-server] instead of [zookeeper].
  3. hello sunwukong,haha
  4. this is a test message

 
 
  • 1
  • 2
  • 3
  • 4

集群配置

单机多broker 集群配置

在单节点部署多个broker。 不同的broker 设置不同的 id，监听端口及日志目录。 例如：

cp config/server.properties config/server-1.properties 
 
 
  • 1

修改server-1.properties

  1. config/server-1.properties:
  2.     broker.id=1
  3.     port=9093
  4.     log.dir=/tmp/kafka-logs-1

 
 
  • 1
  • 2
  • 3
  • 4

启动Kafka服务

sh kafka-server-start.sh ..config/server-1.properties &
 
 
  • 1

启动多个服务，具体操作通单机版一样

多机多broker 集群配置

我用的是vm，可以克隆3个vm，模拟安装配置 
分别在多个节点按上述方式安装Kafka，配置启动多个Zookeeper 实例。zookeeper.properties配置如下：

  1. initLimit=5
  2. syncLimit=2
  3. server.1=192.168.1.102:2888:3888
  4. server.2=192.168.1.103:2888:3888
  5. server.3=192.168.1.104:2888:3888

 
 
  • 1
  • 2
  • 3
  • 4
  • 5

分别配置多个机器上的Kafka服务 设置不同的broke id，修改server.properties

zookeeper.connect=192.168.1.102:2181,192.168.1.102:2181,192.168.1.102:2181
 
 
  • 1

最后我们分别启动zk服务和kafka服务进行验证。

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号