public class KafkaJsonMessagePoller<T> extends Object implements Closeable
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void run()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.