testkafkaeventforwarder()