Error when try to start my application with go_kafka_client included

[elodina]

Error when try to start my application with go_kafka_client included

[vladiacob]

I made a pull request to fix this issues: #2

[vladiacob]

How can I read from kafka from 10 seconds to 10 seconds ? Now is reading when I'm opening the server but after this not retry again.

If I publish messages after consumer was started, consumer will get this messages only after is restarted.

[serejja]

@vladiacob I merged you pull request. Thank you for your contribution!

Not sure about your problem but consider trying config.AutoResetOffset = SmallestOffset as the default value is LargestOffset and the problem sounds like you don't get messages when you produce them earlier than you start the consumer.

[vladiacob]

If I start consumer and after this I start producer I don't get messages in consumer. After this if I stop consumer and start again I get all messages sent before but if I try to send a new message is the same behaviour.

[serejja]

I created a separate issue #6 for this problem. The fix is on the way.

The current issue looks solved so I close it.