Comments (3)
@aakarim, what do you mean by it's capped
. I think only condition is minimum 0. If you set it to a large value, doesn't it retry?
Could you check if setting bigQueryRetryWait
and bigQueryRetry
both to large values help ?
from kafka-connect-bigquery.
@b-goyal Yes it does retry, it just only retries set number of times. I'd like it to keep retrying until the quota has expired (usually after a day). I could multiply it out, so if I have a bigQueryRetryWait
of 15s that means that I need to retry 5,760 times max before giving up, but I'd like the flexibility to just set it as infinite and have it keep retrying forever.
from kafka-connect-bigquery.
bigQueryRetry
is of type int
so it is basically capped at 2147483647
.
The bigQueryRetryWait
is defaulted to 1000ms ( 1sec) . Doc link : https://docs.confluent.io/kafka-connectors/bigquery/current/kafka_connect_bigquery_config.html#:~:text=Importance%3A%20medium-,bigQueryRetryWait,-The%20minimum%20amount
If you set bigQueryRetry
to the highest value possible which is 2147483647
, with 1sec wait before retry, you will be retrying for 68 years.
I believe we do not need any explicit value to make the connector retry for days, if we set it to max, it should serve the purpose.
Does this help?
from kafka-connect-bigquery.
Related Issues (20)
- Version 2.4.4 can't be found
- Frequent BigQueryException HOT 2
- Support for Storage Write API HOT 18
- Support for partition filter required config when using UPSERT
- Convert io.debezium.time.MicroTimestamp to Bigquery TIMESTAMP HOT 2
- Timestamp conversion issue
- ERROR : INVALID_ARGUMENT jobInternalError HOT 2
- Setting kafkaKeyFieldName, when keys are string and topic has no schema, is not working HOT 2
- Connector Not Restarting after BigQueryConnectException HOT 3
- Separate billing project & destination project HOT 2
- Records Duplication in BigQuery when Streaming Data from Kafka Topic via kafka-connect-bigquery HOT 8
- JSON data type is not working HOT 1
- Potenial data consistency issues HOT 5
- Configure batch size on KafkaConnect BigQuery sink connector HOT 2
- Question: Intermediate table cleanup process after merge flush
- Debezium micro-timestamps with negative epochs cause the connector to fail due to string formatting problem in the conversion code
- Not able to send kafka json messages to bigquery
- BQ Connector incorrectly parsing DBZ timestamps with millisecond precision
- De-duplication using insertId
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kafka-connect-bigquery.