Skip to content

Instantly share code, notes, and snippets.

View VictorGil's full-sized avatar

Víctor Gil VictorGil

View GitHub Profile
VictorGil /
Last active August 19, 2019 10:02
Snippet of
final KStream<String, Transfer> transfersKStream =
createInputKStream(stringSerde, configValues.getSchemaRegistryUrl(),
final Serde<AccountBalance> accountBalanceSerde =
final KTable<String,AccountBalance> accountBalancesKTable =
createInputKTable(stringSerde, accountBalanceSerde, builder);
VictorGil / confluentinc_examples.diff
Created August 18, 2019 21:45
The changes which I made to the 5.3.0-post branch code on my local environment to be able to start the Confluence Platform version 5.3.0
diff --git a/connect-streams-pipeline/ b/connect-streams-pipeline/
index 5490d92..4c10e09 100644
--- a/connect-streams-pipeline/
+++ b/connect-streams-pipeline/
@@ -25,7 +25,7 @@ tasks.max=1
# SQLite database stored in the file test.db, use and auto-incrementing column called 'id' to
# detect new rows as they are added, and output to topics prefixed with 'test-sqlite-jdbc-', e.g.
# a table called 'users' will be written to the topic 'test-sqlite-jdbc-users'.