orinciog

Add compression config for Parquest files

9

I've added a config for this plugin in order to specify the compression for parquest files. The setting is called 'parquet.codec' and can have the following values: none, snappy, gzip,...

Accessing windowed table outside stream

3

Hello! I need to access a windowed table from outside stream. (The reason is that I need to obtain Top K users in a time interval. For this I store...

This PR adds a similar feature from connect-ui - ability to specify multiple clusters in SCHEMAREGISTRY_URL env variable. See: https://github.com/lensesio/kafka-connect-ui/issues/43

Keep http connection open for long-time

1

Hi! I'm using thriftpy2 to connect to a hbase thrift server, which has enabled http mode. We need long-lived connections to our http server in order to save time. I...

Add a method to re-run DNS lookup

5

Hello! In Kubernetes world, where an IP of a host can change often, catching all socket errors is not very helpful. For example, if the IP of statsd host is...