Kafa TopicPartition Sınıfı

Giriş

u satırı dahil ederiz

import  org.apache.kafka.common.TopicPartition;

Bu sınıf sanırım hem Kafka Consumer hem de Kafka Producer tarafından kullanılıyor. Ben en çok Kafka Consumer tarafından kullanıldığı örneklere denk geldim. Topic ismi ve partition numarasını taşıyan basit bir sınıf

KafkaConsumer.commitSync metodu

KafkaConsumer.seek metodu

KafkaConsumer.subscribe metodu

tarafından kullanılır

constructor

Kod şöyle

public TopicPartition(String topic, int partition) {
  this.partition = partition;
  this.topic = topic;
}