Results 26 comments of Boris Shilov

Hit this today with ``` "compression.type" = "producer" ``` which Confluent apparently removes from topics, or otherwise silently disallows. In my case I did not actually end up needing this...

I got this working with some tinkering, after needing to generate some configuration `json` for GraalVM to cope with the reflection used in http libs. Writeup coming soon but here's...

Right so to get to this result you need to install GraalVM and add it to your path: ``` brew cask install graalvm/tap/graalvm-ce-java8 export PATH=/Library/Java/JavaVirtualMachines/graalvm-ce-java8-20.0.0/Contents/Home/bin:"$PATH" ``` And then install the...

Indeed, this is good enough for my purposes, thanks! Although with more complex passwords including special characters I suspect this will not work.

I am having a bit of an issue with building the project to test it. I've obtained Gradle 5 and am following the readme. From the project dir I do:...

Thanks, that helped. Testing against my Kafka Connect cluster, which is HTTPs and secured with BasicAuth. I have the following format of env variable: ``` export KAFKA_CONNECT_REST='https://USERNAME:ALPHANUMERICPASSWORD@HOSTNAME:PORT' ``` Then running:...

Checked out the fork/branch and can confirm that at least with `ps` it works. I will test the other commands later but looking at the code as the request method...

I also get these errors when I have messages coming in with an incompatible schema that I need to fix manually. Indeed I also use the `bigQueryRetry` setting and it...

Hey @Cyril-Engels would catching the `BigQueryConnectException` in `BigQuerySinkTask::flush` and throwing a `ConnectException` much like[ we do already](https://github.com/wepay/kafka-connect-bigquery/blob/a6dc6f0f99154174c4f7e4451a9adddc1d520859/kcbq-connector/src/main/java/com/wepay/kafka/connect/bigquery/BigQuerySinkTask.java#L126) with `InterruptedException` not work in this case for failing the task when we...

I see @Cyril-Engels [has a PR already](https://github.com/wepay/kafka-connect-bigquery/pull/262) that seems like a massive step in the right direction to making this connector safe to run with topics that change schemas frequently....