PanasCherepushko

[Pub/Sub to Elasticsearch] Fix error handling

8

This pull request contains many changes in custom ElasticsearchIO to be able to handle failed inserts. Now ElasticsearchIO.Write is not a terminal step but returns JSON with error message to...

Kafka To Elasticsearch Template

9

This is the initial PR for **kafka-to-elasticsearch** Dataflow template. It contains **pom.xml** and the empty directories that will be filled in the future pull requests. As a placeholder for the...

Add debug info to Googlecloud-to-elasticsearch

3

Added optional parameter **verboseDebugMessages** that enables additional output when error occurs. It shows full response when there's an issue writing to Elasticsearch. Changes made by this PR will be discarded...

Route errors to pubsub

5

Changed destination of error messages from BigQuery to Pub/Sub topic.