// load config
        config := gk.NewConfig([]string{"localhost:9092"}, "kaenin")

	// create retry manager (inmem)
	rt := retrymanager.NewInmemManager(3, 2)

	// create sarama client from config
	saramaClient, err := gk.NewSaramaConsumerWithConfig(config)
	if err != nil {
		panic("Unable create sarama client!")
	}

	// create worker
	worker, err := gk.New(config, saramaClient, rt)
	if err != nil {
		log.Fatal(err)
	}

        // set custom recovery when panic
	worker.SetPanicHandler(func(err interface{}) {
		fmt.Println("Error in panic: ", err)
	})

	// register method
	worker.RegisterHandler("konohax", testFunc)

	// start worker
	worker.Start()