GitHub user dxichen opened a pull request:
https://github.com/apache/samza/pull/377
Eventhub connector fix
Key fixes
- Switched Producer source vs destination assumptions in `send`, `register`
- Check `OME.key` if `OME.partitionId` is null for to get partitionId
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dxichen/samza eventhub-connector-fix
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/377.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #377
----
commit 2692bf98ee661544b78615b3e220af5e74971e45
Author: Daniel Chen <[email protected]>
Date: 2017-12-01T00:01:48Z
Fixed admin index, manager log, producer src/dst
commit aaeface2f2f272da7d39952f6b08615ac0570ee2
Author: Daniel Chen <[email protected]>
Date: 2017-12-01T22:30:33Z
Updated envelope partiton id retrieval, ignore itest
----
---
