Reference documentation and code samples for the Cloud Pub/Sub V1 API class Google::Cloud::PubSub::V1::IngestionFailureEvent::ConfluentCloudFailureReason.
Failure when ingesting from a Confluent Cloud source.
Inherits
- Object
Extended By
- Google::Protobuf::MessageExts::ClassMethods
Includes
- Google::Protobuf::MessageExts
Methods
#api_violation_reason
def api_violation_reason() -> ::Google::Cloud::PubSub::V1::IngestionFailureEvent::ApiViolationReason
Returns
- (::Google::Cloud::PubSub::V1::IngestionFailureEvent::ApiViolationReason) — Optional. The Pub/Sub API limits prevented the desired message from being published.
#api_violation_reason=
def api_violation_reason=(value) -> ::Google::Cloud::PubSub::V1::IngestionFailureEvent::ApiViolationReason
Parameter
- value (::Google::Cloud::PubSub::V1::IngestionFailureEvent::ApiViolationReason) — Optional. The Pub/Sub API limits prevented the desired message from being published.
Returns
- (::Google::Cloud::PubSub::V1::IngestionFailureEvent::ApiViolationReason) — Optional. The Pub/Sub API limits prevented the desired message from being published.
#cluster_id
def cluster_id() -> ::String
Returns
- (::String) — Optional. The cluster ID containing the topic being ingested from.
#cluster_id=
def cluster_id=(value) -> ::String
Parameter
- value (::String) — Optional. The cluster ID containing the topic being ingested from.
Returns
- (::String) — Optional. The cluster ID containing the topic being ingested from.
#kafka_topic
def kafka_topic() -> ::String
Returns
- (::String) — Optional. The name of the Kafka topic being ingested from.
#kafka_topic=
def kafka_topic=(value) -> ::String
Parameter
- value (::String) — Optional. The name of the Kafka topic being ingested from.
Returns
- (::String) — Optional. The name of the Kafka topic being ingested from.
#offset
def offset() -> ::Integer
Returns
- (::Integer) — Optional. The offset within the partition of the message that failed to be ingested.
#offset=
def offset=(value) -> ::Integer
Parameter
- value (::Integer) — Optional. The offset within the partition of the message that failed to be ingested.
Returns
- (::Integer) — Optional. The offset within the partition of the message that failed to be ingested.
#partition_id
def partition_id() -> ::Integer
Returns
- (::Integer) — Optional. The partition ID of the message that failed to be ingested.
#partition_id=
def partition_id=(value) -> ::Integer
Parameter
- value (::Integer) — Optional. The partition ID of the message that failed to be ingested.
Returns
- (::Integer) — Optional. The partition ID of the message that failed to be ingested.