Hazelcast Jet TopicsConfig Sınıfı - Topic partition İçin Properties Sağlar

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.kafka.TopicsConfig;

addTopicConfig metodu

Örnek

Şöyle yaparız

String topicName = ...;
TopicsConfig topicsConfig = new TopicsConfig()
topicsConfig.addTopicConfig(new TopicConfig(topicName));

Örnek

Şöyle yaparız

TopicsConfig topicsConfig = new TopicsConfig()
  .addTopicConfig(new TopicConfig(topic1Name)
    // 20 total records will be skipped from topic1
    .addPartitionInitialOffset(0, 5L)
    .addPartitionInitialOffset(1, 5L)
    .addPartitionInitialOffset(2, 5L)
    .addPartitionInitialOffset(3, 5L))
  .addTopicConfig(new TopicConfig(topic2Name)
    // 10 total records will be skipped from topic2
    .addPartitionInitialOffset(0, 5L)
    .addPartitionInitialOffset(2, 5L))