Two Storm supervisors running in a 3-node configuration: one "head" node (nimbus) and two worker nodes. Each supervisor node runs a supervisor under supervision.
Multi-lang topology using Python and our streamparse library. Works fine when running on a single machine. Spout reads off Kafka and inserts tuples into
| package kstreams_demo | |
| import java.lang.{Integer => JInt} | |
| import java.util.Properties | |
| import kstreams_demo.converters._ | |
| import org.apache.kafka.clients.consumer.{ConsumerConfig, ConsumerRecord} | |
| import org.apache.kafka.common.serialization.Serdes | |
| import org.apache.kafka.streams.kstream._ | |
| import org.apache.kafka.streams.kstream.internals.TimeWindow |
| Thank you for your interest in Fluence Labs projects. | |
| In order to clarify the intellectual property license | |
| granted with Contributions from any person or entity, Fluence Labs | |
| must have a Contributor License Agreement ("CLA") on file that has | |
| been signed by each Contributor, indicating agreement to the license | |
| terms below. This license is for your protection as a Contributor as | |
| well as the protection of Fluence Labs and its users; it does not | |
| change your rights to use your own Contributions for any other purpose. | |
| This contribution license is based on the Apache Contribution License |