Commit Graph

133 Commits

Author SHA1 Message Date
Fabio José ad2074d48d Use of (un)marshallers
Reduce the boilerplate

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 22:06:09 -03:00
Fabio José 5df373310e Kafka marshallers and unmarshallers for json
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 22:05:30 -03:00
Fabio José 0b11866d83 Fix doc reference for headers type
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 21:35:21 -03:00
Fabio José d8b24f8953 Typing the header's value
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 21:34:39 -03:00
Fabio José 14e873d3f2 Typing the header's value
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 21:34:11 -03:00
Fabio José 87bea3cca2 Tests for kafka structured producer
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-16 21:27:21 -03:00
Fabio José ca377dbb61 How to use binary kafka producer
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-14 18:16:08 -03:00
Fabio José 5b53529dcd Change the use of procuder constructor
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-14 18:15:21 -03:00
Fabio José 43945a9356 Remove the unused contructor
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 23:21:29 -03:00
Fabio José 1f58ddfc88 Use of common marshal interfaces
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 22:20:55 -03:00
Fabio José aabd8c7847 Readme for kafka module
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 21:35:43 -03:00
Fabio José 667f22a060 Meaninful name for kafka tests
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 21:34:58 -03:00
Fabio José 9ad2486176 Remove unused resources
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 21:34:27 -03:00
Fabio José 9568fc339f Use the common interfaces
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 21:34:04 -03:00
Fabio José 2d0538f4f9 Define the common interfaces
Common interfaces for unmarshallers

Meaninful names for kafka tests

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-13 21:31:57 -03:00
Fabio José dc97d6f565 Fixing the name references
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-12 22:27:41 -03:00
Fabio José d2497338f3 Tests for kafka consumer using binary format
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 22:20:00 -03:00
Fabio José 4482e2200b Tests for kafka producer using binary format
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 22:19:16 -03:00
Fabio José 4bea5a311f Java docs
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 22:18:26 -03:00
Fabio José e4237f3a26 Kafka Consumer for cloudevents
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 22:18:02 -03:00
Fabio José a525b08ddf Change the reference to functional interface header mapper
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 22:04:11 -03:00
Fabio José 18a4578b0c Add license docs
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-10 21:54:50 -03:00
Fabio José 98b3d8980b type for tests
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-04 21:21:50 -03:00
Fabio José 6237e569d0 Cloud events kafka producer
Binary marshal

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-04 21:21:24 -03:00
Fabio José de1e54272c Map the values as byte array
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-04 21:16:28 -03:00
Fabio José 7467513636 java doc
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 22:01:06 -03:00
Fabio José 60bbac06de java doc
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 22:00:26 -03:00
Fabio José 469ba5a81e Kafka header mapper
Implementation for 0.2

Unit tests

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 21:58:07 -03:00
Fabio José aa3d5b75af Kafka extension mapper
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 21:49:48 -03:00
Fabio José 049fc8c7d7 Kafka Attribute mapper
Unit tests

Fixes due the tests

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 21:49:14 -03:00
Fabio José 4e6695525b Kafka clients consumer example config
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 21:18:03 -03:00
Fabio José bcc9fd4784 Set version to 0.3.0
Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-03 21:07:11 -03:00
Fabio José 5d29d4f00d Kafka Binding
Build configuration

Attributer mapper for v0.2

Signed-off-by: Fabio José <fabiojose@gmail.com>
2019-09-02 22:11:46 -03:00