Hi, We are trying to build an application using the go_kafka_client, for
managing the consumer creation etc. We find it very convenient and easy to
use. Thanks for building!
But in the go_kafka_client code we see a lot of panics.
For example we created a consumer for a topic that doesn't exist, like
below:
consumer.StartStatic(map[string]int{topic: config.NumConsumerFetchers})
which in turn does
go c.createMessageStreams(topicCountMap) -> since this is calling
createMessageStreams
in a go routine, we are not able to recover from the panic, when its thrown
inside
Here is the place that does panic (partition_assignment.go):
*partitionsForTopic, err := coordinator.GetPartitionsForTopics(myTopics)*
*if err != nil { panic(fmt.Sprintf("Failed to obtain partitions for
topics: %s, topics: %v", err, myTopics)) --> this panic makes our application
crash}*
We do see there is a panic handler for the zookeeper coordinator but not
for the go_kafka_client package. What is the recommended way to handle
panics from go_kafka_client?
Thanks,
Chandra.
--
You received this message because you are subscribed to the Google Groups
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
