public class KafkaPersistWriterTask extends Object implements Runnable
KafkaPersistWriter
Constructor and Description |
---|
KafkaPersistWriterTask(KafkaPersistWriter writer) |
public KafkaPersistWriterTask(KafkaPersistWriter writer)
Copyright © 2018 The Apache Software Foundation. All rights reserved.