Permalink
Commits on Jun 22, 2015
  1. Add simpler kafka producer API

    Can now directly write messages without having to create intermediary
    `KeyedMessage` or `ProducerData` objects.
    nicktelford committed Jun 22, 2015
  2. Properly proxy Kafka's Producer API for 0.8

    This prevents the underlying Kafka Producer API from accidentally
    leaking out of the `KafkaProducerFactory`.
    nicktelford committed Jun 22, 2015
  3. Add JacksonDecoder and JacksonEncoder for Kafka.

    Includes implementations for both Kafka 0.7 and Kafka 0.8.
    nicktelford committed Jun 22, 2015
Commits on Jun 19, 2015
  1. Merge pull request #29 from kvanvranken/develop

    Allow classes that "? extend Partitioner" in the producer builder
    nicktelford committed Jun 19, 2015
  2. Merge pull request #31 from Trundle/fix_fd_leak

    Fix FD leak in SocketHealthCheck.
    nicktelford committed Jun 19, 2015
Commits on Jan 26, 2015
  1. Disable publishing site to github

    Until I can get this working, it's disabled
    nicktelford committed Jan 26, 2015
  2. Fix broken Maven plugins

    These things were blocking the release.
    nicktelford committed Jan 26, 2015
Commits on Dec 16, 2014
  1. Add an initial delay to Kafka consumer threads

    Consumers will now wait a configurable time (2 seconds, by default)
    before starting. This allows the connector to complete any startup tasks
    (e.g. re-balancing) before consumption begins.
    nicktelford committed Dec 16, 2014
Commits on Nov 19, 2014
Commits on Oct 8, 2014
Commits on Oct 1, 2014
  1. Fix incorrect Kafka consumer properties

    The backported `KafkaConsumerFactory` for 0.7 was configuring some
    properties with the incorrect name.
    nicktelford committed Oct 1, 2014
  2. Fix SynchronousConsumer not shutting down service

    On a fatal error, when configured to do so, the SynchronousConsumer
    should shut down the service. However, it was not being registered as a
    `ServerListener`.
    nicktelford committed Oct 1, 2014
  3. Use increment operator

    nicktelford committed Oct 1, 2014
Commits on Sep 24, 2014
Commits on Sep 8, 2014
Commits on Sep 1, 2014
  1. Fix Curator namespace config never being valid

    Curator expects namespaces to omit the leading `/`, whereas ZooKeeper
    expects the leading `/`. This causes `CuratorFactory` to always fail to
    build an instance.
    
    Let's be defensive and strip any leading `/` from the configured
    ZooKeeper namespace when initializing the Curator instance.
    
    Fixes #25.
    nicktelford committed Sep 1, 2014
  2. Make Kafka Producer's Managed

    Producer's should be properly managed by the Dropwizard lifecycle.
    
    Also fixes incorrect capitalization in the producer package name.
    nicktelford committed Sep 1, 2014
Commits on Aug 28, 2014
  1. Add dropwizard-extra-kafka7 module

    Provides a consumer-only implementation for the older 0.7 release of
    Apache Kafka.
    nicktelford committed Aug 28, 2014
  2. Remove unnecessary imports

    nicktelford committed Aug 28, 2014
Commits on Aug 27, 2014
  1. Fix CuratorHealthCheck failing with namespace

    When Curator has been initialized with a namespace, the
    `CuratorHealthCheck` would always fail.
    nicktelford committed Aug 27, 2014
  2. Fixes to KafkaConsumerFactory.

    Fixes incorrect names on some setter methods and adds the
    `@JsonProperty` annotation to the recovery options.
    mjwillson committed with nicktelford Aug 27, 2014