benstopford · August 16, 2017 21:28
diff --git a/UnbundledDatabaseSudoJavaExample2.java b/UnbundledDatabaseSudoJavaExample2.java
 //Inside the Kafka Streams thread (extending the example above) push the enriched orders into a topic of their own. 
 enrichedOrders.through(“enriched-orders-topic”);

 //Now build a table from that topic, which will be pushed into the “enriched-orders-store”
 KTable enrichedOrdersTable = builder.table(..., “enriched-orders-topic”, “enriched-orders-store”);
	//Inside the Kafka Streams thread (extending the example above) push the enriched orders into a topic of their own.
	enrichedOrders.through(“enriched-orders-topic”);

	//Now build a table from that topic, which will be pushed into the “enriched-orders-store”
	KTable enrichedOrdersTable = builder.table(..., “enriched-orders-topic”, “enriched-orders-store”);