fix bug 534: allow group_id for kafka consumer