major changes on KafkaSink

Netflix / suro

Netflix's distributed Data Pipeline

Apache License 2.0

794 stars 170 forks source link

Closed stevenzwu closed 9 years ago

stevenzwu commented 9 years ago

cleanup a lot of legacy props in constructor
we should use the kafka.etc map to all optional kafka props
support new boolean flag of normalizeRoutingKey so that we can get rid of PlatformKafkaSink
support partitioner config with StickyPartitioner opted in
fix test code

cloudbees-pull-request-builder commented 9 years ago

NetflixOSS » suro » suro-pull-requests #8 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #177 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

NetflixOSS » suro » suro-pull-requests #9 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #178 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

NetflixOSS » suro » suro-pull-requests #10 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #179 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

NetflixOSS » suro » suro-pull-requests #11 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #180 FAILURE Looks like there's a problem with this pull request