AwsKinesisFailureReason(mapping=None, *, ignore_unknown_fields=False, **kwargs)Failure when ingesting from an AWS Kinesis source.
.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
Attributes |
|
|---|---|
| Name | Description |
stream_arn
:noindex: |
str
Optional. The stream ARN of the Kinesis stream being ingested from. |
partition_key
:noindex: |
str
Optional. The partition key of the message that failed to be ingested. |
sequence_number
:noindex: |
str
Optional. The sequence number of the message that failed to be ingested. |
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.
|