Hi All, I have been trying to get started with Kafka. I have set up an 0.8.2 broker as per the quick start. With a single node broker I am able to run the scripts in the bin folder to successfully produce and consume messages.
I then tried to write some Scala code to use the new 0.8 Producer API to produce messages. However nothing seems to appear on the consumer. I modified the producer code to wait for the broker's metadata response. That blocks and then times out. The only difference I can see apart from using the new Producer API is all my previous tests were run inside the VM Kafka is installed on. Where as my code is running on the host machine and connecting into Kafka. I put some code into get the topics metadata to confirm connectivity to Kafka. That prints the topic metadata correctly before hanging on the send(...).get(). I have also checked the topic is set for a replication factor of 1. I can't see anything in the Kafka logs either. All I see on the broker is a message when the Producer times out saying the client disconnected. Anyone got any ideas what might be making Kafka fail to commit the messages? I really want to start playing with Kafka however I seem to have fallen at the first hurdle. Thanks, Charlie M
