Custom endpoint_url and 'ShardId'

[nicholasball]

• Add custom endpoint_url to consumer/producer and state
• Return 'ShardId' in item

[dmrib]

Looks good to me!

[dmrib]

Is there anything I can do to move this forward? I really need this PR merged :)

[borgstrom]

Hi @nicholasball,

I'm 👍 on the end point change, but would like to change the semantics of how the shard_id is returned to keep the data envelope stable for existing use cases.

We also will need a test that covers return_shard_id.

[borgstrom]

I do not like the idea mutating the item.

Instead of adding the ShardId to the item what do you think about adding another option to init (something like return_shard_id=False) that if true would change the yield to:

if self.return_shard_id:
    yield shard_id, item
else:
    yield item