Changes for configurable kafka ports