README.md in fluent-plugin-gcloud-pubsub-custom-0.3.4.pre vs README.md in fluent-plugin-gcloud-pubsub-custom-0.3.4
- old
+ new
@@ -5,14 +5,14 @@
This plugin is forked from https://github.com/mdoi/fluent-plugin-gcloud-pubsub
## Overview
-[Cloud Pub/Sub](https://cloud.google.com/pubsub/) Input/Output(BufferedOutput) plugin for [Fluentd](http://www.fluentd.org/) with [gcloud](https://googlecloudplatform.github.io/gcloud-ruby/) gem
+[Google Cloud Pub/Sub](https://cloud.google.com/pubsub/) Input/Output(BufferedOutput) plugin for [Fluentd](http://www.fluentd.org/) with [google-cloud](https://googlecloudplatform.github.io/google-cloud-ruby/) gem
-- [Publish](https://googlecloudplatform.github.io/gcloud-ruby/docs/v0.12.2/Gcloud/Pubsub/Topic.html#publish-instance_method) messages to Cloud Pub/Sub
-- [Pull](https://googlecloudplatform.github.io/gcloud-ruby/docs/v0.12.2/Gcloud/Pubsub/Subscription.html#pull-instance_method) messages from Cloud Pub/Sub
+- Publish messages to Google Cloud Pub/Sub
+- Pull messages from Google Cloud Pub/Sub
## Preparation
- Create a project on Google Developer Console
- Add a topic of Cloud Pub/Sub to the project
@@ -94,10 +94,11 @@
max_messages 1000
return_immediately true
pull_interval 0.5
pull_threads 2
format json
+ parse_error_action exception
enable_rpc true
rpc_bind 0.0.0.0
rpc_port 24680
</source>
```
@@ -125,9 +126,13 @@
- Pulling messages by intervals of specified seconds.
- `pull_threads` (optional, default: `1`)
- Set number of threads to pull messages.
- `format` (optional, default: `json`)
- Set input format. See format section in http://docs.fluentd.org/articles/in_tail
+- `parse_error_action` (optional, default: `exception`)
+ - Set error type when parsing messages fails.
+ - `exception`: Raise exception. Messages are not acknowledged.
+ - `warning`: Only logging as warning.
- `enable_rpc` (optional, default: `false`)
- If `true` is specified, HTTP RPC to stop or start pulling message is enabled.
- `rpc_bind` (optional, default: `0.0.0.0`)
- Bind IP address for HTTP RPC.
- `rpc_port` (optional, default: `24680`)