Spawn 1 connection (gen_server) per partition, since offset must be managed per-partition

also, feed the partition back to the callback