Fix task_done checks when no previous commit exists; add test
assertEqual (assertEquals deprecated)
Make TIMEOUT_MS configurable in test_kafka_consumer__blocking