Dinesh Kumar
Dinesh Kumar
Describe the default configuration for the application, and also the need for override for each part. eg: queue, poll time, ack timeout, thread pool size.
Stencil points to a server which holds file descriptors for the protobufs. We could add doc/script to setup a SimpleHTTPServer for the given protobufs.
We can't change bigquery schema once created specifically renaming field, but in protobuf context renaming field is allowed. Since the data type is not changed, we should be able to...
Right now, beast assumes the data is in protobuf format. We should customize it to other format Create a parser based on configuration (className) and using reflection to create it.
Failed to push records to sink FailureStatus{cause=com.google.cloud.bigquery.BigQueryException: www.googleapis.com, message='null'} We've cases where push failed (which's retriable), but we don't have the logs, which needs to fixed.
* Insert records in kafka * beast should push to bigquery * verify the data in bigquery
Hi, PlainTask's very helpful, and pretty much impressed with its simplicity and features :) Thanks for the creators / contributors. 1. I've looked at the code, a single file, every...
# Description Since config file changes would restart the service, it's required to view the diff. Keep it configurable so we can exclude when it has credentials. This is really...