Comments (5)
Just to make sure I understand, you'd prefer it if the connector would stay alive (but at error state) and keep checking for new configuration?
from kafka-connect-jdbc.
Yup,
Otherwise, we would need to restart "connect-distributed" each time an error occurs even while setting up / adding a connector. If there is stronger error checking with the REST API, recovering and taking corrective actions would be possible. The standard HTTP codes for REST errors could be sent back to let the app developer know that the call has failed. I hope that makes sense
from kafka-connect-jdbc.
@joshivinay Thanks for reporting this issue. We made some improvements of Kafka Connect in CP 3.0 release that supports status tracking of connector and tasks. In case that a connector is not correctly initialized and started, the connector will transit to FAILED
state, however, the exceptions during connector start are properly caught. As a result, the Worker is not crashed you should be able to reconfigure the connector with correct configurations.
CP 3.0 also provides REST API report status of connectors and tasks. You should be able to use that API to inform the App of the connector status.
from kafka-connect-jdbc.
Okay,
We will check it out with the CP 3.0 release.
Thanks
Vinay Joshi
Kwartile, Inc.
Email: [email protected] [email protected]
On Thu, Jun 2, 2016 at 12:15 PM, Liquan Pei [email protected]
wrote:
@joshivinay https://github.com/joshivinay Thanks for reporting this
issue. We made some improvements of Kafka Connect in CP 3.0 release that
supports status tracking of connector and tasks. In case that a connector
is not correctly initialized and started, the connector will transit to
FAILED state, however, the exceptions during connector start are properly
caught. As a result, the Worker is not crashed you should be able to
reconfigure the connector with correct configurations.CP 3.0 also provides REST API report status of connectors and tasks. You
should be able to use that API to inform the App of the connector status.—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
#57 (comment),
or mute the thread
https://github.com/notifications/unsubscribe/AKzV2J3_K-_ecfjJbYYhlxtMb-LQw6Iaks5qHnv0gaJpZM4H5Q1M
.
from kafka-connect-jdbc.
Connect in distributed mode should not crash if a connector fails. There were improvements in 3.0 that @Ishiihara mentioned. In 3.1, there are further robustness improvements with https://issues.apache.org/jira/browse/KAFKA-4042.
from kafka-connect-jdbc.
Related Issues (20)
- Please tell me the command to connect the source and sink connectors to postgresql
- Connector Fails After a Network Issue and Doesn't Reconnect for Ten Minutes HOT 1
- `org.postgresql.util.PSQLException` should cause the task to fail
- String not converted to jsonb - Error: column is of type jsonb but expression is of type character varying
- Specify consumer group while reading messages
- Support for PostgreSQL's OID data type
- Phoenix thin client jdbc
- Debezium Postgres connector error: io.debezium.connector.postgresql.converters.PostgresCloudEventsProvider not a subtype
- How to convert CLOB data to VARCHAR2 before inserting to Oracle table using Kafka connect jdbc sink?
- JdbcSourceConnector Failed to get current time from DB using Generic and query 'SELECT CURRENT_TIMESTAMP'
- Firebird - Error to get CURRENT_TIMESTAMP
- db.timezone is not applied on the endDate
- CVE-2024-1597 Postgresql Version Vulnerability HOT 1
- Mode config option is not marked as required
- How to build a fat jar file by this repo?
- ERROR [jdbc-sqlserver-sink|task-0] WorkerSinkTask{id=jdbc-sqlserver-sink-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:188)
- Allow users to configure current timestamp query.
- JdbcSinkConfig fails to initialize if run in Turkish locale (tr-TR)
- JDBC SOURCE connector adding extra " and \s to json columns
- Jdbc Sink Connector - configuration validation runs before replacement when using a file Config Provider
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-jdbc.