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.