cdc

Hi and thank you for this great API.

Please made a Postman collection for version 3.

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource

-Dpact.rootDir="target/pact-classes" didn’t work for me.
env "pact.rootDir=target/pact-classes" bash did

...because of the "."

I am working with an Odata API interface which presents timestamp values such as lastModified in a format similar to `//Date(1530144000000+0530)/. Would it be possible to get such date formats supported. If this is something that could be supported I'd be happy to contribute this sort of functionality, a steer in the right direction would certainly be appreciated.

Jun	JUL	Aug
	17
2020	2021	2022

cdc

Here are 236 public repositories matching this topic...

debezium / debezium

supabase / realtime

disease-sh / API

confluentinc / examples

hazelcast / hazelcast-jet

ververica / flink-cdc-connectors

2ndQuadrant / pglogical

JumpMind / symmetric-ds

dotnetcore / CanalSharp

actiontech / dtle

xtoolbox / TeenyUSB

azagniotov / stubby4j

uber / storagetapper

mongodb / mongo-kafka

framiere / a-kafka-story

JarvusInnovations / lapidus

hpgrahsl / kafka-connect-mongodb

neo4j-contrib / neo4j-streams

vllogic / vllink_lite

ITV / scala-pact

debezium / debezium-incubator

bersler / OpenLogReplicator

disneystreaming / pg2k4j

rusuly / MySqlCdc

castorm / kafka-connect-http

hrbrmstr / cdcfluview

alext234 / coronavirus-stats

jwplayer / southpaw

lirantal / awesome-contract-testing

mysql-time-machine / replicator

Improve this page

Add this topic to your repo