VictorGil

        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

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