Hazelcast Jet WriteKafkaP Sınıfı

Giriş
Şu satırı dahil ederiz 

import com.hazelcast.jet.kafka.impl.WriteKafkaP;

exactlyOnce Alanı

Kod şöyle. Producer sadece bir kere yazmayı garanti eder

public final class WriteKafkaP<T, K, V> implements Processor {

  ...
  private final boolean exactlyOnce;
}

Örnek

Şöyle yaparız. testJob çalışınca WriteKafkaP devreye girer

CREATE OR REPLACE MAPPING testMap (
  __key INT,
  ticker VARCHAR,
  price DECIMAL,
  amount BIGINT)
TYPE IMap
OPTIONS (
  'keyFormat'='int',
  'valueFormat'='json-flat'
);

INSERT INTO testMap VALUES
  (1, 'ABCD', 5.5, 10),
  (2, 'EFGH', 14, 20);

CREATE JOB testJob
OPTIONS (
  'processingGuarantee' = 'exactlyOnce'
) AS
SINK INTO testTopic
SELECT __key, ticker, price, amount FROM testMap

 private final boolean exactlyOnce;