Fixed Topic autocreate to make sure it is created by publisher.
Fixed Consumer to subscribe on scheduler thread because offset resolution requests happen in during subscribe.