Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Kafka (Create Adapter → Pipeline (Source → Kafka Sink) → Create Kafka Adapter (validate event schema)
  • MQTT (Create Adapter → Pipeline (Source → MQTT Sink) → Create MQTT Adapter (validate event schema)
  • MySQL(Create Adapter → Pipeline (Source → MySQL Sink) → Create MySQL Adapter (validate event schema)
  • InfluxDB (Create Adapter → Pipeline (Source → InfluxDB Sink) → Create InfluxDB Adapter (validate event schema)
  • How to deal with database set adapters?


Kafka
  • 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 ) 
        • 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

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

...