Reference documentation and code samples for the Cloud PubSub V1 Client class AwsMskFailureReason.
Failure when ingesting from an Amazon MSK source.
Generated from protobuf message google.pubsub.v1.IngestionFailureEvent.AwsMskFailureReason
Namespace
Google \ Cloud \ PubSub \ V1 \ IngestionFailureEventMethods
__construct
Constructor.
| Parameters | |
|---|---|
| Name | Description |
data |
array
Optional. Data for populating the Message object. |
↳ cluster_arn |
string
Optional. The ARN of the cluster of the topic being ingested from. |
↳ kafka_topic |
string
Optional. The name of the Kafka topic being ingested from. |
↳ partition_id |
int|string
Optional. The partition ID of the message that failed to be ingested. |
↳ offset |
int|string
Optional. The offset within the partition of the message that failed to be ingested. |
↳ api_violation_reason |
ApiViolationReason
Optional. The Pub/Sub API limits prevented the desired message from being published. |
getClusterArn
Optional. The ARN of the cluster of the topic being ingested from.
| Returns | |
|---|---|
| Type | Description |
string |
|
setClusterArn
Optional. The ARN of the cluster of the topic being ingested from.
| Parameter | |
|---|---|
| Name | Description |
var |
string
|
| Returns | |
|---|---|
| Type | Description |
$this |
|
getKafkaTopic
Optional. The name of the Kafka topic being ingested from.
| Returns | |
|---|---|
| Type | Description |
string |
|
setKafkaTopic
Optional. The name of the Kafka topic being ingested from.
| Parameter | |
|---|---|
| Name | Description |
var |
string
|
| Returns | |
|---|---|
| Type | Description |
$this |
|
getPartitionId
Optional. The partition ID of the message that failed to be ingested.
| Returns | |
|---|---|
| Type | Description |
int|string |
|
setPartitionId
Optional. The partition ID of the message that failed to be ingested.
| Parameter | |
|---|---|
| Name | Description |
var |
int|string
|
| Returns | |
|---|---|
| Type | Description |
$this |
|
getOffset
Optional. The offset within the partition of the message that failed to be ingested.
| Returns | |
|---|---|
| Type | Description |
int|string |
|
setOffset
Optional. The offset within the partition of the message that failed to be ingested.
| Parameter | |
|---|---|
| Name | Description |
var |
int|string
|
| Returns | |
|---|---|
| Type | Description |
$this |
|
getApiViolationReason
Optional. The Pub/Sub API limits prevented the desired message from being published.
| Returns | |
|---|---|
| Type | Description |
ApiViolationReason|null |
|
hasApiViolationReason
setApiViolationReason
Optional. The Pub/Sub API limits prevented the desired message from being published.
| Parameter | |
|---|---|
| Name | Description |
var |
ApiViolationReason
|
| Returns | |
|---|---|
| Type | Description |
$this |
|
getReason
| Returns | |
|---|---|
| Type | Description |
string |
|