Page History

...

• 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
• 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
  • Validate in live preview: Contain 7 event properties
• 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

...