Chris Egerton
Chris Egerton
It should also be noted that a quick workaround I've discovered is to silently swallow `ApiException`s whose status code is 401 and immediately retry, so this isn't a super urgent...
I've published a KIP that would add support for this to the Kafka Connect REST API; if anyone has the time to take a look, I'd be interested to hear...
@adelcast This looks straightforward, useful, and well-implemented. Do you think it might make sense to expand on the existing unit tests for the `BigQuerySinkTask` class to verify this change?
@adelcast apologies for the delay! Been working on my own feature for this connector and it's eaten my life a little bit :) I think there are two ways we...
@criccomini Think you nailed it with > a regex would only work on startup. The Kafka Connect framework doesn't yet provide consumer refreshing Seems like the best fix would be...
Believe @criccomini has it right. Theoretically (I have to qualify this since I haven't actually seen it tested yet and things may have changed since the last time I touched...
@criccomini This seems like a great abstraction to place over the connector and allow it to service a variety of use cases. Excited to see this thing still growing and...
@mtthien-tma what's the name of the column you added to your Postgres table?
@mtthien-tma that doesn't appear to be a name of a column in the BigQuery schema in the log you provided. Are you sure that's the only column? The ones listed...
Ah, gotcha. You mentioned you're using Schema Registry; can you provide the Avro schema for the data that's breaking on the connector? I should let you know--right now I suspect...