Files
spring-cloud-dataflow-samples/kafka-samples/http-ingest
Ilayaperumal Gopinathan 4cc758982b Add Kafka Streams samples
- Add `http-ingest` source application that adds function composition example
 - Move the KStream samples from SCSt samples and modify them for SCDF stream

Address review comments

 - Add depenency management BOM
 - Add README
2019-03-18 16:01:02 -04:00
..
2019-03-18 16:01:02 -04:00
2019-03-18 16:01:02 -04:00
2019-03-18 16:01:02 -04:00
2019-03-18 16:01:02 -04:00
2019-03-18 16:01:02 -04:00
2019-03-18 16:01:02 -04:00

# HTTP Ingest Source

This source application is an extension of out-of-the-box HTTP source application.

The `http-ingest` has a function bean definition that looks like:

```
@Bean
public Function<String, Long> sendAsUserClicks() {
  return value -> Long.parseLong(value);
}

```

When this function bean is enabled, the incoming `String` value is converted to `Long` value.
When sending user clicks count as `Long` we can enable this function for the `http-ingest` while the same application can be used for sending the user region `String` value.

To build this application:

./mvnw clean package