Выключение Кафка Потребитель

Question

я читал до деталей Кафки высокого уровня потребителя в этом link и увидел внизу заявление -

На практике, более общий шаблон должен использовать сон на неопределенный срок и использовать выключения крюк для запуска чистого отключения.

Есть ли примеры для этого или указатели, которые могли бы помочь?

Answer 1

Это будет пример бесконечного цикла

public void run() { 
    try { 
     consumer.subscribe(topics); 
     while (true) { 
      ConsumerRecords<String, String> records = consumer.poll(Long.MAX_VALUE); 
     //do something 
     } 
    } catch (WakeupException e) { 
     // do nothing we are shutting down 
    } finally { 
     consumer.close(); 
    } 
    } 

    public void shutdown() { 
    consumer.wakeup(); 
    } 
} 

И это будет ваш выключение крючок.

@PostConstruct 
    private void init(){ 
     addShutdownHook(); 
    } 

private void addShutdownHook(){ 
    Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() { 

      @Override 
      public void run() { 
       shutdown(); 
      } 
     })); 
    }