Class AwsMskFailureReason (2.28.0) 

AwsMskFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)

Failure when ingesting from an Amazon MSK source.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Attributes
Name Description
cluster_arn :noindex: str
Optional. The ARN of the cluster of the topic being ingested from.
kafka_topic :noindex: str
Optional. The name of the Kafka topic being ingested from.
partition_id :noindex: int
Optional. The partition ID of the message that failed to be ingested.
offset :noindex: int
Optional. The offset within the partition of the message that failed to be ingested.
api_violation_reason :noindex: google.pubsub_v1.types.IngestionFailureEvent.ApiViolationReason
Optional. The Pub/Sub API limits prevented the desired message from being published. This field is a member of oneof_ reason.