King Chung Huang

Allow suppression of (or explicitly enable) messages for updates and deletes

1

For tables with a primary key, Bottled Water transmits the table row as the message for inserts and updates, and a message value of null for deletes. In tables that...

Optionally specify sort order for initial snapshot

2

The initial database snapshot does a `SELECT *` which returns rows in an unspecified order. This can cause the initial batch of messages in Kafka to appear "out of order"...

Proposal: New implementation of ECSCluster

3

I use `ECSCluster` heavily, but I find it has lots of small implementation issues that make it hard to reliably run large Dask clusters. Here's a laundry list of some...

ECSCluster does not de-provision tasks after failing to connect to scheduler

11

**What happened**: If ECSCluster successfully runs a scheduler task but then fails to connect to the scheduler, an error is raised and the scheduler task is left active. The task...

/var/run symlinked to /run in 3.7 image

2

The `alpine:3.7` image has a symlink from `/var/run` to `/run`, whereas 3.6 and 3.5 did not. Is this intentional? I can't find any notes about it. The difference threw me...

Produce to multiple topics

3

Is there a way to produce messages to one of several topics? When using kafkacat in the Producer mode, a single topic is specified with the `-t` option. I'd like...

Setting message headers when piping in messages

1

kafkacat can set message headers in producer mode with the `-H ` option. If I'm piping in messages to kafkacat to produce to a topic, is there a way that...

Sentry integration for error reporting

1

One of the things that ends up in my entrypoints is initializing Sentry for error tracking. It might be interesting to integrate this into rash using the Sentry Rust SDK....

Syntax error creating roles/users on Redshift

1

### Terraform Version ``` # terraform --version Terraform v0.12.26 ``` ### Affected Resource(s) - postgresql_role ### Terraform Configuration Files ```hcl resource "postgresql_role" "user" { for_each = local.database_users name = each.key...

Increase timeout

5

Is there a way to increase the timeout for creating/updating connectors? Kafka Connect can take a really long time when processing lots of connectors. I keep getting errors like this:...