<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def should_try_kafka_again(error):
 """Determine if the error means to retry or fail, True to retry."""

    msg = 'Unable to retrieve'
    return isinstance(error, KafkaException) and str(error).startswith(msg)