class KafkaSenderExporter {

  @Activate
  public void activate(Config config, BundleContext context, Map<String, String> properties) {
    sender = KafkaSender.newBuilder()
        .bootstrapServers(config.bootstrapServers())
        .encoding(config.encoding())
        .messageMaxBytes(config.messageMaxBytes())
        .overrides(getOverrides(properties))
        .topic(config.topic())
        .build();
    reg = context.registerService(Sender.class, sender, new Hashtable<String, String>(properties));
  }

}