[
https://issues.apache.org/jira/browse/KAFKA-609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13499235#comment-13499235
]
Yang Ye commented on KAFKA-609:
-------------------------------
We found this is not a real issue. The reason is simply because that the
target (08) brokers didn't actually start up. We see following log in all three
target brokers:
[2012-11-13 00:30:09,655] INFO [Log Manager on Broker 6] Starting log flusher
every 1000 ms with the following overrides Map() (kafka.log.LogManager)
[2012-11-13 00:30:09,685] ERROR Uncaught exception in thread 'kafka-acceptor':
(kafka.utils.Utils$)
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:119)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59)
at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:52)
at kafka.network.Acceptor.run(SocketServer.scala:134)
at java.lang.Thread.run(Thread.java:619)
[2012-11-13 00:31:45,327] INFO [Kafka Server 6], shutting down
(kafka.server.KafkaServer)
[2012-11-13 00:31:45,330] INFO Shutdown Kafka scheduler
(kafka.utils.KafkaScheduler)
[2012-11-13 00:31:45,331] INFO [Socket Server on Broker 6], shutting down
(kafka.network.SocketServer)
That's because the java process last run didn't get closed completely and the
socket is still been used. No wonder no data is produced to the target cluster.
> System Test Transient Failure 9001 (Migration tool) - ConsoleConsumer
> terminates after "can't rebalance after 4 retries"
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-609
> URL: https://issues.apache.org/jira/browse/KAFKA-609
> Project: Kafka
> Issue Type: Bug
> Reporter: John Fung
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
