Skip to content

Instantly share code, notes, and snippets.

View VictorGil's full-sized avatar

Víctor Gil VictorGil

View GitHub Profile
@VictorGil
VictorGil / TransfersRecordingServiceJoinStreams.java
Last active August 19, 2019 10:02
Snippet of TransfersRecordingServiceJoinStreams.java
final KStream<String, Transfer> transfersKStream =
createInputKStream(stringSerde, configValues.getSchemaRegistryUrl(),
builder);
final Serde<AccountBalance> accountBalanceSerde =
createAccountBalanceSerde(configValues.getSchemaRegistryUrl());
final KTable<String,AccountBalance> accountBalancesKTable =
createInputKTable(stringSerde, accountBalanceSerde, builder);
@VictorGil
VictorGil / confluentinc_examples.diff
Created August 18, 2019 21:45
The changes which I made to the https://github.com/confluentinc/examples 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/jdbcavroksql-connector.properties b/connect-streams-pipeline/jdbcavroksql-connector.properties
index 5490d92..4c10e09 100644
--- a/connect-streams-pipeline/jdbcavroksql-connector.properties
+++ b/connect-streams-pipeline/jdbcavroksql-connector.properties
@@ -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'.
-connection.url=jdbc:sqlite:/usr/local/lib/retail.db
+connection.url=jdbc:sqlite:/home/user1/java/eclipse/19.08.06_kafka/sqlite_db_files/retail.db