Skip to content

Commit 4407681

Browse files
committed
added kstream bounded mem 2
1 parent 1379cb1 commit 4407681

File tree

15 files changed

+0
-266
lines changed

15 files changed

+0
-266
lines changed

cdc-debezium-mongo/config/debezium-source-mongo-with-capture-scope-database.json

100644100755
File mode changed.

kafka-connect-postgres-to-mongo/Dockerfile

-3
This file was deleted.

kafka-connect-postgres-to-mongo/config/connector_mongo.json

-20
This file was deleted.

kafka-connect-postgres-to-mongo/pom.xml

-80
This file was deleted.

kafka-connect-postgres-to-mongo/src/main/java/org/hifly/kafka/smt/FlattenJsonData.java

-96
This file was deleted.

kafka-connect-postgres-to-mongo/src/test/java/org/hifly/kafka/smt/KeyFromFieldsTest.java

-41
This file was deleted.

kafka-smt-aspectj/config/connector_mongo.json

-1
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,5 @@
1616
"predicates": "IsFoo",
1717
"predicates.IsFoo.type": "org.apache.kafka.connect.transforms.predicates.TopicNameMatches",
1818
"predicates.IsFoo.pattern": "test"
19-
2019
}
2120
}

kafka-streams-k8s/dependency-reduced-pom.xml

100644100755
File mode changed.

kafka-streams-k8s/prometheus/jmx_prometheus_javaagent-0.20.0.jar

100644100755
File mode changed.

kafka-streams-k8s/prometheus/kafka_streams.yml

100644100755
File mode changed.

kafka-streams-k8s/src/main/java/org/hifly/kafka/demo/streams/stream/BoundedMemoryRocksDBConfig.java

100644100755
File mode changed.

kafka-streams-k8s/src/main/java/org/hifly/kafka/demo/streams/stream/WindowedWordCountApp.java

100644100755
File mode changed.

kafka-streams/dependency-reduced-pom.xml

100644100755
File mode changed.

scripts/bootstrap-connect-postgres-to-mongo.sh

-20
This file was deleted.

scripts/tear-down-connect-postgres-to-mongo.sh

-5
This file was deleted.

0 commit comments

Comments
 (0)