KafkaConsumer? switches from subscribe to assign
Change-Id: Id7fee31a2c52b25d0478c08c01a2f784fe0948d5