kafka producer failed

[Job-Selina Wu]

Hi,

    When the messages was send to Kafka by KafkaProducer, It always failed
when the message more than 3000 - 4000 messages. The error is shown below.
I am wondering if any topic size I need to set at Samza configuration?


[2015-07-23 17:30:03,792] WARN
[console-consumer-84579_Selinas-MacBook-Pro.local-1437697324624-eecb4f40-leader-finder-thread],
Failed to find leader for Set([http-demo,0])
(kafka.consumer.ConsumerFetcherManager$LeaderFinderThread)
kafka.common.KafkaException: fetching topic metadata for topics
[Set(http-demo)] from broker [ArrayBuffer()] failed
        at
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72)
        at
kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93)
        at
kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)
^CConsumed 4327 messages

Your reply and comment will be highly appreciated.


Sincerely,
Selina