THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Precondition:
- None
- Use StreamPipes internal Kafka
- Before:
- Create Adapter (Machine Data Simulator / Flow Rate)
- Create Pipeline (Machine Data Simulator → Kafka Sink)
- Configure Kafka Sink (Selector: kafka_publisher publisher )
- Type: input; Selector: topic; Value: #testname
- Type: input; Selector: host; Value: kafka
- Type: input; Selector: port; Value: 9092 Type: radio; Selector: access-mode; Value: Unauthenticated
- input Selector: topic Value: #testname
- Type: input Selector: host Value: kafka
- Type: input Selector: port Value: 9092
- Type: radio Selector: access-mode Value: Unauthenticated
- Configure Kafka Sink (Selector: kafka_publisher publisher )
- Test:
- Create Kafka Adapter
- (Selector: Apache_Kafka )
- Type: input Selector: host Value: kafka
- Type: input Selector: port Value: 9092
- Type: radio Selector: access-mode Value: Unauthenticated
- Type: radio Selector: topic Value: #testname
- Format: json
- Mark as timestamp: timestamp
- Name: #testname
- (Selector: Apache_Kafka )
- Validate in live preview: Contain 7 event properties
- Create Kafka Adapter
- Clean Up
- Delete pipeline
- Delete adapter (Kafka)
- Delete adapter (Machine Data Simulator)
Connect
- File Set / Stream
- HTTP Set / Stream
- Image Set / Stream
- ISS Location (Can be used to test Dashboard map)
- Machine Data Simulator
- OPC UA
- PLC adapters?
- Random Data Set / Stream
- ROS
- Slack?
- HTTP Server
...