AwsMskFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Failure when ingesting from an Amazon MSK source.
This message has oneof_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.
.. _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.
|
schema_violation_reason
:noindex: |
google.pubsub_v1.types.IngestionFailureEvent.SchemaViolationReason
Optional. The Pub/Sub message failed schema validation. This field is a member of oneof_ reason.
|