journal.publisher: Fix multiple issues and add logging
Revealed by actually running kafka with docker.
Test Plan
tox
Migrated from D863 (view on Phabricator)
Staging instance, all changes can be removed at any time
Revealed by actually running kafka with docker.
tox
Migrated from D863 (view on Phabricator)