bytewax.connectors.kafka.error

Error handling related stuff.

Classes

class KafkaError

Bases:

• Generic[K, V]

Custom KafkaErorr class that holds both the exception and the message itself.

err: KafkaError

msg: KafkaSourceMessage[bytewax.connectors.kafka._types.K, bytewax.connectors.kafka._types.V]