unleash-subscriber.java

/**
* Custom subscriber that will be notified on all UnleashEvents.
* The extended Log4JSubscriber will log out the events that are not
* handled in this extension.
**/
public class KafkaUnleashSubscriber extends Log4JSubscriber {
  @Override
  public void on(@NotNull UnleashEvent event) {
    // many events come through here, we only care about responses
    if (event instance of FeatureToggleResponse) {
      // event has ALL toggles, filter out those you care about
      // apply toggles to consumer
    }
  }
}