test_class.file: exporter-sender-kafka/src/test/java/io/zipkin/brave/exporter/sender/kafka/KafkaSenderExporterTest.java
test_class.identifier: KafkaSenderExporterTest
test_case.body: @Test
    public void testConfig() {
      KafkaSenderExporter exporter = new KafkaSenderExporter();
      Map<String, String> properties = new HashMap<String, String>();
      properties.put("kafka.myprop", "myvalue");
      BundleContext context = mock(BundleContext.class);
      Config config = mock(Config.class);
      when(config.bootstrapServers()).thenReturn("server1");
      when(config.encoding()).thenReturn(Encoding.JSON);
      when(config.topic()).thenReturn("mytopic");
      exporter.activate(config, context, properties);
    }
test_case.class_method_signature: KafkaSenderExporterTest.testConfig()
test_case.full_signature: @Test public void testConfig()
test_case.identifier: testConfig
test_case.invocations: put mock mock thenReturn when bootstrapServers thenReturn when encoding thenReturn when topic activate
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConfig()
focal_class.declarator: OVERRIDE_PREFIX = "kafka."
focal_class.modifier: private static final
focal_class.original_string: private static final String OVERRIDE_PREFIX = "kafka.";
focal_class.type: String
focal_class.var_name: OVERRIDE_PREFIX
focal_class.declarator: reg
focal_class.modifier: private
focal_class.original_string: private ServiceRegistration<Sender> reg;
focal_class.type: ServiceRegistration<Sender>
focal_class.var_name: reg
focal_class.declarator: sender
focal_class.modifier: private
focal_class.original_string: private KafkaSender sender;
focal_class.type: KafkaSender
focal_class.var_name: sender
focal_class.file: exporter-sender-kafka/src/main/java/io/zipkin/brave/exporter/sender/kafka/KafkaSenderExporter.java
focal_class.identifier: KafkaSenderExporter
focal_class.class_method_signature: KafkaSenderExporter.activate(Config config, BundleContext context, Map<String, String> properties)
focal_class.full_signature: @Activate public void activate(Config config, BundleContext context, Map<String, String> properties)
focal_class.identifier: activate
focal_class.modifiers: @Activate public
focal_class.parameters: (Config config, BundleContext context, Map<String, String> properties)
focal_class.return: void
focal_class.signature: void activate(Config config, BundleContext context, Map<String, String> properties)
focal_class.class_method_signature: KafkaSenderExporter.getOverrides(Map<String, String> properties)
focal_class.full_signature: private HashMap<String, String> getOverrides(Map<String, String> properties)
focal_class.identifier: getOverrides
focal_class.modifiers: private
focal_class.parameters: (Map<String, String> properties)
focal_class.return: HashMap<String, String>
focal_class.signature: HashMap<String, String> getOverrides(Map<String, String> properties)
focal_class.class_method_signature: KafkaSenderExporter.deactive()
focal_class.full_signature: @Deactivate public void deactive()
focal_class.identifier: deactive
focal_class.modifiers: @Deactivate public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void deactive()
focal_method.body: @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));
    }
focal_method.class_method_signature: KafkaSenderExporter.activate(Config config, BundleContext context, Map<String, String> properties)
focal_method.full_signature: @Activate public void activate(Config config, BundleContext context, Map<String, String> properties)
focal_method.identifier: activate
focal_method.invocations: build topic overrides messageMaxBytes encoding bootstrapServers newBuilder bootstrapServers encoding messageMaxBytes getOverrides topic registerService
focal_method.modifiers: @Activate public
focal_method.parameters: (Config config, BundleContext context, Map<String, String> properties)
focal_method.return: void
focal_method.signature: void activate(Config config, BundleContext context, Map<String, String> properties)