Yaron Schneider
|
3ef025c604
|
change headers (#679)
|
2021-02-09 18:57:55 -08:00 |
|
Yaron Schneider
|
58e92479ac
|
Add kafka max message bytes and pubsub partition key (#669)
* add kafka max message bytes and pubsub partition key
* linter
|
2021-02-08 11:14:52 -08:00 |
Artur Souza
|
e6dadfab6c
|
TTL in PubSub. (#565)
* TTL in PubSub.
* Handle message TTL only if component cannot handle it.
* Removig dead code for overflow check in pubsub expiration.
|
2020-12-29 14:28:52 -08:00 |
Joni Collinge
|
2e6b84ae40
|
Merge remote-tracking branch 'origin/master' into jjcollinge/pubsub-context
|
2020-11-02 09:05:16 +00:00 |
|
Yaron Schneider
|
182d204111
|
Add close method to pub/sub (#494)
* add close method to pub/sub
* linter
|
2020-10-12 19:06:33 -07:00 |
halspang
|
f647d9eedb
|
Upgrade golang lint to 1.31 (#490)
Upgrade golang lint to 1.31.0
https://github.com/dapr/components-contrib/issues/439
|
2020-10-12 12:54:15 -07:00 |
|
jjcollinge
|
19442e67c8
|
update pubsub components to use new context
|
2020-07-28 10:03:23 +01:00 |
|
jjcollinge
|
410628af3d
|
add context to pubsub handler signature
|
2020-07-07 12:37:15 +01:00 |
Kyle Housley
|
0c4cade71f
|
Add pubsub support for kafka (#315)
* fixes issue #8: adds kafka as pubsub component
* fixes issue #8: adds kafka as pubsub component
* pubsub kafka: modifies readme
* pubsub kafka: fixes bug
* pubsub kafka: fixes bug
* pubsub kafka: changes are per PR review
* changes as PR review
* removed unused field
* only close channel once
* working kafka pubsub
* add testing for metadata parsing
* linting
* remove unused PublishTopic, remove loglevel
* Use one consumer group for subscriptions
Co-authored-by: Roberto J Rojas <robertojrojas@gmail.com>
Co-authored-by: Yaron Schneider <yaronsc@microsoft.com>
Co-authored-by: Young Bu Park <youngp@microsoft.com>
Co-authored-by: Aman Bhardwaj <amanbha@users.noreply.github.com>
|
2020-04-27 19:53:04 -07:00 |