* store() - done * setting sasl credentials dynamically - done * subscriptions() * epoch related fields on partitions - as in v2.1.0 of librdkafka - done * metadata commit while committing offsets - done * Maybe offsetForTimes