Skip to content

Commit f782f01

Browse files
committed
Major UI improvements
1 parent 4d60142 commit f782f01

File tree

1 file changed

+2
-19
lines changed

1 file changed

+2
-19
lines changed

src/main/java/com/kafkastream/service/EventsListener.java

Lines changed: 2 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -75,28 +75,11 @@ public static void main(String[] args)
7575
.withKeySerde(Serdes.String())
7676
.withValueSerde(customerSerde));
7777

78-
customerKTable.filter((key, value) ->
79-
{
80-
System.out.println("customerKTable.key: " + key);
81-
System.out.println("customerKTable.value: " + value);
82-
return true;
83-
});
84-
85-
streamsBuilder.stream("order", Consumed.with(Serdes.String(), orderSerde))
86-
.selectKey((key, value) -> value.getCustomerId().toString()).to("order-to-ktable", Produced.with(Serdes.String(), orderSerde));
87-
KTable<String, Order> orderKTable = streamsBuilder.table("order-to-ktable", Materialized.<String, Order, KeyValueStore<Bytes, byte[]>>as(orderStateStore.name())
78+
KTable<String, Order> orderKTable = streamsBuilder.table("order", Materialized.<String, Order,
79+
KeyValueStore<Bytes, byte[]>>as(orderStateStore.name())
8880
.withKeySerde(Serdes.String())
8981
.withValueSerde(orderSerde));
9082

91-
//Print orderKTable
92-
orderKTable.filter((key, value) ->
93-
{
94-
System.out.println("orderKTable.key: " + key);
95-
System.out.println("orderKTable.value: " + value);
96-
return true;
97-
});
98-
99-
10083
KTable<String, Greetings> greetingsKTable = streamsBuilder.table("greetings", Materialized.<String, Greetings,
10184
KeyValueStore<Bytes, byte[]>>as(greetingsStateStore.name())
10285
.withKeySerde(Serdes.String())

0 commit comments

Comments
 (0)