Kafka Connect DatagenConnector Sınıfı - Test İçindir

Giriş

Bu connector test amaçlı rastgele veri üretir. quickstart şemasında hazır (Quick Start Predefined Schemas) nesneler var. 

Hazır nesne listesi burada

Açıklaması şöyle

Parameter Description                                         Default

max.interval Max interval between messages (ms)                         500

iterations Number of messages to send from each task, or less than 1 for unlimited -1

Örnek

Java ile yazılmış bir test kodu burada

Örnek - Orders

Hazır gelen nesnelerden bir tanesi Orders. Bu nesneleri orders_json isimli kuyruğa JSON olarak göndermek için şöyle yaparız. Toplam 1000 tane nesne üretir

{
  "name": "datagen-orders",
  "config": {
    "connector.class": "io.confluent.kafka.connect.datagen.DatagenConnector",
    "kafka.topic": "orders_json",
    "quickstart": "orders",
    "key.converter": "org.apache.kafka.connect.storage.StringConverter",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter.schemas.enable": "false",
    "max.interval": 1000,
    "iterations": 1000,
    "tasks.max": "1"
  }
}