KeyedStream<Event, String> keyedStream = inputStream.keyBy(event -> event.logKey())