но на бою нет. Может кто-нибудь подскажет в чем проблема, буду благодарен
                  
                  
                  
                  
                  
                  Zookeeper config:
                  
                  
                  dataDir=/etc/zookeeper
                  
                  
                  
                  
                  
                  #dataLogDir=/var/lib/zookeeper/logs
                  
                  
                  
                  
                  
                  # the port at which the clients will connect
                  
                  
                  
                  
                  
                  clientPort=2181
                  
                  
                  
                  
                  
                  maxClientCnxns=4096
                  
                  
                  
                  
                  
                  initLimit=5
                  
                  
                  
                  
                  
                  syncLimit=2
                  
                  
                  
                  
                  
                  autopurge.snapRetainCount=10
                  
                  
                  
                  
                  
                  autopurge.purgeInterval=1
                  
                  
                  
                  
                  
                  server.1=10.0.57.126:2888:3888
                  
                  
                  
                  
                  
                  server.3=10.0.57.127:2888:3888
                  
                  
                  
                  
                  
                  server.2=10.0.57.128:2888:3888
                  
                  
                  
                  
                  
                  Server properties:
                  
                  
                  zookeeper.connect=10.0.57.126:2181,10.0.57.127:2181,10.0.57.128:2181
                  
                  
                  
                  
                  
                  log.dirs=/var/lib/kafka/data
                  
                  
                  
                  
                  
                  broker.id=1(ну и соответственно 2, 3 на других серверах)
                  
                  
                  
                  
                  
                   
                  
                  
                  
                  
                  
                  group.initial.rebalance.delay.ms=0
                  
                  
                  
                  
                  
                  log.retention.check.interval.ms=300000
                  
                  
                  
                  
                  
                  log.retention.hours=168
                  
                  
                  
                  
                  
                  log.segment.bytes=1073741824
                  
                  
                  
                  
                  
                  num.io.threads=16
                  
                  
                  
                  
                  
                  num.network.threads=8
                  
                  
                  
                  
                  
                  num.partitions=1
                  
                  
                  
                  
                  
                  num.recovery.threads.per.data.dir=2
                  
                  
                  
                  
                  
                  offsets.topic.replication.factor=3
                  
                  
                  
                  
                  
                  socket.receive.buffer.bytes=102400
                  
                  
                  
                  
                  
                  socket.request.max.bytes=104857600
                  
                  
                  
                  
                  
                  socket.send.buffer.bytes=102400
                  
                  
                  
                  
                  
                  transaction.state.log.min.isr=2
                  
                  
                  
                  
                  
                  transaction.state.log.replication.factor=3
                  
                  
                  
                  
                  
                  zookeeper.connection.timeout.ms=6000
                  
                  
                  
                  
                  
                  delete.topic.enable=True
                  
                  
                  
                  
                  
                  replica.fetch.max.bytes=5242880
                  
                  
                  
                  
                  
                  message.max.bytes=5242880
                  
                  
                  
                  
                  
                  max.message.bytes=5242880
                  
                  
                  
                  
                  
                  default.replication.factor=3
                  
                  
                  
                  
                  
                  min.insync.replicas=2
                  
                  
                  
                  
                  
                  replica.fetch.wait.max.ms=200
                  
                  
                  
                  
                  
                  replica.lag.time.max.ms=1000
                  
                  
                  
                  
                  
                  advertised.listeners=PLAINTEXT://:9092
                  
                  
                
Логи смотри, права на директории, доступность портов меж хостами, названия хостов. Без логов - это угадайка. На вскидку - num.partitions=1
без логов можно и бабушку поспрашивать
Error while creating ephemeral at /brokers/ids/0, node already exists Вот это выдает
в конфигах - broker id уникальны?
Обсуждают сегодня