Comments (2)
Hi @mubeta06 ,
Sure, timestamp parsing is managed by implementations of this interface:
https://github.com/castorm/kafka-connect-http/blob/master/kafka-connect-http/src/main/java/com/github/castorm/kafka/connect/http/response/timestamp/spi/TimestampParser.java
You can see a couple of examples here:
https://github.com/castorm/kafka-connect-http/blob/master/kafka-connect-http/src/main/java/com/github/castorm/kafka/connect/http/response/timestamp/EpochMillisTimestampParser.java
https://github.com/castorm/kafka-connect-http/blob/master/kafka-connect-http/src/main/java/com/github/castorm/kafka/connect/http/response/timestamp/NattyTimestampParser.java
Then it's a matter of configuring your parser:
https://github.com/castorm/kafka-connect-http#httpresponserecordtimestampparser
I hope this helps.
Thanks,
Best regards.
from kafka-connect-http.
I forgot, you can implement and use this without contributing it to the project, but contributions are welcome!
Best regards.
from kafka-connect-http.
Related Issues (20)
- Offset isn't committed directly HOT 2
- Maven package build fails on JDK 11.0.11 HOT 2
- Parse response of the following format {"items":{"k1": {"k1":"v1"} ,"k2":{"k2":"v2"}}} HOT 1
- URL encoding of query parameters HOT 1
- Http source or sink not taking HTTP PROXY define in system level in REDHAT 8 HOT 1
- Handling multi-line JSON response HOT 1
- Make timestamp parser able to use optional property? HOT 1
- [DepShield] (CVSS 7.5) Vulnerability due to usage of org.apache.commons:commons-compress:1.20
- How to transform with REST API
- Does the connector support SSL certification verification
- java.lang.NoClassDefFoundError: freemarker/template/Configuration HOT 1
- Broken link: The "See examples" link on https://castorm.github.io/kafka-connect-http/ is broken
- Connector vulnerabilities HOT 1
- DepShield Deprecation Notice
- Add support for unordered results
- Duplicated records with low `http.timer.interval.millis` HOT 1
- AWS Signv4 authentication
- Maven build failed HOT 2
- Add Bearer Token support for HTTP authentication HOT 1
- Node not found - parse error - flat arry
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-http.