Tranquility - logging

I’ve been playing with DruidBeams’ builder, instead of using ‘fromConfig’ which has been working for me so far. However, when instantiating my beam and sending message i get sent = false SendResult, and no log message to pin point the problem.
So been since looking for ways to get meaningful logs from tranquility. Tried a few things (1) excluding all other log4j jar from dependencies, (2) tweaking my log4j properties to log trace level for both io.druid and com.metamx, (3) even tried creating my own Logger that extends Emiter. None of these have produced any results.

Here’s how i build my beam:

def apply[T](config: DruidBeamConfig, f: T => DateTime): Beam[T] = {
  val builder: Builder[T,T] = DruidBeams.builder[T](f)
    .curatorFactory(
      CuratorFrameworkFactory.builder()
        .connectString(config.zookeeperConnectString.reduce(_+","+_))
        .retryPolicy(new ExponentialBackoffRetry(1000, 3)))
    .discoveryPath(config.discoveryPath)
    .tuning(
      ClusteredBeamTuning.builder()
        .segmentGranularity(config.segmentGranularity)
        .windowPeriod(config.windowPeriod)
        .partitions(config.partitionCount)
        .replicants(config.replicantCount)
        .build())
    .location(
      DruidLocation(
        new DruidEnvironment(config.indexServiceKey, config.serviceName),
        config.datasourceName))
    .rollup(DruidRollup(
      SchemalessDruidDimensions(config.dimensionExclusion),
      config.aggregators,
      config.queryGranularity)
    )
    .emitter(
      new ServiceEmitter(
        "tranquility",
        "localhost",
        new LoggingEmitter(new MyLogger(logger), LoggingEmitter.Level.DEBUG, Jackson.newObjectMapper())

Here’s my log4j config:

log4j.rootCategory=DEBUG, console
log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.target=System.err
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{yy/MM/dd HH:mm:ss,SSS} %p (%t) %C: %m%n

log4j.logger.com.mypackage=TRACE
log4j.logger.com.metam=TRACE

log4j.logger.io.druid=TRACE

the only com.metamx message i get when building my beam and sending messages is:

17/03/12 00:45:22,960 INFO (main) com.metamx.common.logger.Logger: Loaded class[class io.druid.guice.ExtensionsConfig] from props[druid.extensions.] as [ExtensionsConfig{searchCurrentClassloader=true, directory=‘extensions’, hadoopDependenciesDir=‘hadoop-dependencies’, hadoopContainerDruidClasspath=‘null’, loadList=null}]

17/03/12 00:45:23,816 INFO (main) ?: Adding resolver for scheme[disco].

pom:

<dependency>
    <groupId>io.druid</groupId>
    <artifactId>tranquility-core_2.10</artifactId>
    <version>${druid.tranquilty-core.version}</version>
    <exclusions>
        <exclusion>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
        </exclusion>
        <exclusion>
            <groupId>ch.qos.logback</groupId>
            <artifactId>logback-classic</artifactId>
        </exclusion>
    </exclusions>
</dependency>

org.slf4j slf4j-api ${slf4j.version} org.slf4j slf4j-log4j12 1.7.24 log4j log4j 1.2.17 ```

Anyone ran into similar logging issue? any help greatly appreciated.