cloudevents
/
sdk-java
mirror of https://github.com/cloudevents/sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
779 Commits 19 Branches 32 Tags 4 MiB
Commit Graph

149 Commits

Author SHA1 Message Date
Fabio José b0483f3a8c Filter to remove non-ce headers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:04:02 -03:00
Fabio José 272c6ad568 Testing for kafka producer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:53:49 -03:00
Fabio José 838a730258 Top-level marshallers for kafka 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:43:27 -03:00
Fabio José 528563b563 License comment and new attributes 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:31:15 -03:00
Fabio José af39059327 Private constructor to prevent instances creationg 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:30:50 -03:00
Fabio José c11ca15fc4 Kafka header mapper for (un)marshalling 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:30:04 -03:00
Fabio José 9b41ae001d Kafka extension mapper for (un)marshalling 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:29:43 -03:00
Fabio José 8327a97b04 Kafka Attributes mapper for spec 0.2 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:19:49 -03:00
Fabio José cb3364e714 Override (de)serializers 
The value (de)serializer always must be bytearray

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 21:05:05 -03:00
Fabio José f6a85d0b40 Document the dependency config 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:19:54 -03:00
Fabio José 1f6a6009d9 Document the use of (un)marshalelrs 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 22:02:02 -03:00
Fabio José d4c1cb2825 Tests for structured kafka consumer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:39:24 -03:00
Fabio José 4e4ded70dc Right name for the test 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:39:02 -03:00
Fabio José 089f976540 structure unmarshaller definition 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-18 21:38:37 -03:00
Fabio José 90d08f0678 Boilerplate 
KafkaConsumer and KafkaPRoducer to delegate calls, as internal attribute by composition

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-17 22:58:40 -03:00
Fabio José cdb638157d Impl the send that pass a callback arg 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-16 22:12:26 -03:00
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