GitHub user haohui opened a pull request:
https://github.com/apache/storm/pull/906
STORM-1357. Support writing to Kafka streams in Storm SQL.
This PR adds supports to stream the results from Storm SQL to
`KafkaProducer`.
It contains two main components:
* Allow plugging in producer config in `CREATE TABLE`.
* Add serializers for primitive SQL fields.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/storm STORM-1357
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/906.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 #906
----
commit 34c484b1ed9e4300a1d98256c1283511e70b62f2
Author: Xin Wang <[email protected]>
Date: 2015-09-18T05:58:06Z
use new kafka producer api
commit d054dfd2f5b76c14aa752cff2cb9a23c0070701e
Author: Xin Wang <[email protected]>
Date: 2015-09-18T06:05:21Z
use new kafka producer configs
commit d71fe3506264be385675c5ae8dd0ba4ac2e23ab6
Author: Xin Wang <[email protected]>
Date: 2015-11-05T03:27:30Z
update TestUtils kafka configs
commit 15dec2ec1901d46116c37e114909306a3b79fd85
Author: Xin Wang <[email protected]>
Date: 2015-09-18T07:19:44Z
correct storm-kafka readme file
correct readme file: link & configs
commit 02a19ca8ed82b860fc3e869c88a608b90ce9d790
Author: Haohui Mai <[email protected]>
Date: 2015-11-25T19:30:22Z
STORM-1352. Trident should support writing to multiple Kafka clusters.
commit a74f421995e83d3ac241dd674723776f434743f8
Author: Haohui Mai <[email protected]>
Date: 2015-12-01T02:58:29Z
STORM-1357. Support writing to Kafka streams in Storm SQL.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
