Hazelcast Jet KafkaSqlConnector Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.sql.impl.connector.kafka.KafkaSqlConnector;

CREATE MAPPING ... Type Kafka cümlesi sonucunda bu connector yaratılır. Burada preferred local parallellism için bir soru var