Wednesday, August 2, 2023

Kafka Streams KeyValueStore Arayüzü

Giriş
Şu satırı dahil ederiz 
import org.apache.kafka.streams.state.KeyValueStore;
delete metodu
İmzası şöyle
V delete(K key)
Açıklaması şöyle
Reset the state of the materialized view by calling the PurgeableStoreProvider.purge(), KeyValueStore.delete() or equivalent method to remove all existing records from the view's state store.

No comments:

Post a Comment

kafka-consumer-groups.sh komutu

Giriş Bir topic'i dinleyen consumer'ları gösterir. Aynı topic'i dinleyen consumer group'ları olabilir. Her topic farklı part...