Michał Suchwałko

Message Producer Context

2

For easier extendability I think Put message should have signature like: ``` PutMessage(ctx context.Context, message pubsub.ProducerMessage) error { ``` With current implementation wrapping this method with per request or per...

Multiple topics subscription

2

Currently go-pubsub doesn't allow passing list of topics for single kafka consumer. ``` type MessageSourceConfig struct { ConsumerGroup string Topic string Brokers []string Offset int64 MetadataRefreshFrequency time.Duration Version *sarama.KafkaVersion }...

This would allow using simplified version of sink creation with ability to modify config with FuncKeys and other options not available in current flow.