Ashley Jeffs
Ashley Jeffs
We're seeing a panic when running kinesis to kafka: ``` bufio.(*Reader).ReadByte(0xc00d39e6c0) /usr/local/go/src/bufio/bufio.go:271 +0xa5 compress/flate.(*decompressor).huffSym(0xc0011bb908, 0xc0011bb938) /usr/local/go/src/compress/flate/inflate.go:720 +0x102 compress/flate.(*decompressor).huffmanBlock(0x0?) /usr/local/go/src/compress/flate/inflate.go:495 +0x45 compress/flate.(*decompressor).Read(0xc0011bb908, {0xc00195c000, 0x2000, 0xc0020ec090?}) /usr/local/go/src/compress/flate/inflate.go:348 +0x5b compress/gzip.(*Reader).Read(0xc001f57348, {0xc00195c000, 0x2000, 0x2000})...
I've merged the PgSQL repos for CDC into `./internal/impl/postgresql` and have done some tidy up to get it (almost) compiling. There's a bunch of TODOs where we have panics and...
Currently all parquet timestamps are serialized with nanosecond precision, we should expand the capabilities of the `parquet_encode` processor so that users can override this default in config.
Updates the tools install tasks to use TOOLS_BIN_DIR, it needed to be made absolute in order to satisfy GOBIN.