Was broker running on 52.194 encountering some error ?
Can you check broker log on 52.194 ?
Thanks
On Mon, Dec 25, 2017 at 5:03 PM, G~D~Lunatic <747620...@qq.com> wrote:
> i‘ m a beginner of kafka. i usde kafka_2.11-0.9.0.1. my kafka built in
> two virtual machine which ip are 52.193 and 52.194
>
> when i use commonds both in 52.193./kafka-console-producer.sh
> --broker-list 192.168.52.193:9092 --topic shuaige
> and
> ./kafka-console-consumer.sh --zookeeper 192.168.52.195:2181 --topic
> shuaige --from-beginning
>
> the message of producer was shown in consumer terminal.
>
> but when i use 52.193 as producer and 52.194 as consumer
> ./kafka-console-producer.sh --broker-list 192.168.52.194:9092 --topic
> shuaige
> and
> ./kafka-console-consumer.sh --zookeeper 192.168.52.195:2181 --topic
> shuaige --from-beginning
>
> it shows WARN Error while fetching metadata with correlation id 0 :
> {ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
> [2017-12-25 15:22:19,571] WARN Error while fetching metadata with
> correlation id 1 : {ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.
> NetworkClient)
> [2017-12-25 15:22:19,675] WARN Error while fetching metadata with
> correlation id 2 : {ttes=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.
> NetworkClient)
>
> here is my configure,server.properties
> # The id of the broker. This must be set to a unique integer for each
> broker.
> broker.id=0
>
> ############################# Socket Server Settings
> #############################
>
> listeners=PLAINTEXT://:9092
> port=9092
> # The port the socket server listens on
> #port=9092
>
> # Hostname the broker will bind to. If not set, the server will bind to
> all interfaces
> #host.name=localhost
> host.name=192.168.52.193
>
> advertised.host.name = localhost
>
> advertised.port=9092
>
> num.network.threads=3
>
> # The number of threads doing disk I/O
> num.io.threads=8
>
> # The send buffer (SO_SNDBUF) used by the socket server
> socket.send.buffer.bytes=102400
>
> # The receive buffer (SO_RCVBUF) used by the socket server
> socket.receive.buffer.bytes=102400
> # The maximum size of a request that the socket server will accept
> (protection against OOM)
> socket.request.max.bytes=104857600
>
>
> ############################# Log Basics #############################
>
>
> num.partitions=1
>
>
> num.recovery.threads.per.data.dir=1
> log.retention.hours=168
> message.max.byte=5242880
> default.replication.factor=2
> replica.fetch.max.bytes=5242880
> log.segment.bytes=1073741824
> log.retention.check.interval.ms=300000
>
> ############################# Zookeeper #############################
>
> zookeeper.connect=192.168.52.195:2181,192.168.52.196:2181,1
> 92.168.52.197:2181
> # Timeout in ms for connecting to zookeeper
> zookeeper.connection.timeout.ms=6000
>
>
>
>
> ..thanks for you help
