Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

configurable kafka partitioner #2284

Merged
merged 6 commits into from
Aug 24, 2016
Merged

configurable kafka partitioner #2284

merged 6 commits into from
Aug 24, 2016

Commits on Aug 23, 2016

  1. Add RunBytes to EventStringFormatter

    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    b23ed80 View commit details
    Browse the repository at this point in the history

  2. Make common.Time hashable

    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    48fbe60 View commit details
    Browse the repository at this point in the history

  3. Configurable kafka partitioning 

    - add config settings to configure partition strategy
- add config settings to configure partitioner selecting only reachable
  partitions
- Store kafka message in data.values so original message including partition
  selection is still available on retry
- make kafka message key configurable
- update changelog
    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    8a5af70 View commit details
    Browse the repository at this point in the history

  4. Introduce kafka table driven testing 

    - replace kafka integration tests with table driven integration tests
- add integrations tests using batch publishing
- add integration tests using different partitioner configurations
    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    05fba1a View commit details
    Browse the repository at this point in the history

  5. kafka partitioner unit tests

    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    fb8463e View commit details
    Browse the repository at this point in the history

  6. Add kafka partitioner settings to config files

    urso committed Aug 23, 2016
    Configuration menu
    Copy the full SHA
    3597027 View commit details
    Browse the repository at this point in the history