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

133 Commits

Author SHA1 Message Date
Fabio José d25aaf8f49
Merge pull request #90 from fhussonnois/master 
Add new CloudEventsKafkaHeaders class for kafka API
 2020-03-04 20:12:40 -03:00
Fabio José a79f8f9431
Merge pull request #78 from cricket007/patch-1 
Fix Kafka Transport references
 2020-03-04 20:09:25 -03:00
kpark 833db5bd92 Map extensions with prefix for Kafka CloudEvent header 
Signed-off-by: kpark <kpark@guidewire.com>

Apply suggestions from code review

Co-Authored-By: Sergei Egorov <bsideup@gmail.com>
Signed-off-by: kpark <kpark@guidewire.com>
 2020-02-27 10:02:04 -08:00
Florian Hussonnois a5f88c3408 Add new CloudEventsKafkaHeaders class for kafka API 
This commit add a new CloudEventsKafkaHeaders helper class used to build the Kafka headers
that should be attached either a binary or structured event message.

Signed-off-by: Florian Hussonnois <florian.hussonnois@gmail.com>
 2020-01-28 15:57:18 +01:00
Fabio José 0b1d2d27d5 🔖 Set versions to 1.2.0 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-12-30 08:50:43 -03:00
Jordan Moore d0178c0bea kafka s/Transport/Protocol/g 
Signed-off-by: Jordan Moore <crikket.007@gmail.com>
 2019-12-18 12:21:05 -06:00
Ruben Romero Montes 3049f587d8 Fix base64 marshalling 
Signed-off-by: Ruben Romero Montes <rromerom@redhat.com>
 2019-12-03 23:12:35 +01:00
Fabio José c3460ee150 🔖 Set versions to 1.1.0 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-28 20:42:21 -03:00
Fabio José 0376e12e11 🔖 Set versions to 1.0.1 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-28 20:34:49 -03:00
Fabio José cbab54ed88 🔥 Remove skip long running annotation 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 15:11:59 -03:00
Fabio José 7a1326f182 ➖ Remove the kafka embedded deps 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 15:11:42 -03:00
Fabio José 962d10cb48 🔥 Remove the dependency of embedded kafka 
Now using MockProducer

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 15:07:57 -03:00
Fabio José 457962402a ✨ Constructor to provide custom kafka producer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 15:07:39 -03:00
Fabio José b451c1d7d6 🔥 Remove the dependency of embedded kafka 
Now using MockConsumer

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 14:25:39 -03:00
Fabio José d732c0d153 🔥 Remove the dependency of embedded kafka 
Now using MockConsumer

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 14:14:05 -03:00
Fabio José 2dfed7e782 🔥 Remove the dependency of embedded kafka 
Now using MockConsumer

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 14:06:25 -03:00
Fabio José c205299065 ✨ Constructor to provide custom kafka consumer 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 13:59:09 -03:00
Fabio José c047c754f0 ➕ Dep for jackson core 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 13:46:24 -03:00
Fabio José 88c078af57 ⬆️ Bump the jackson version to 2.10.1 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 11:13:56 -03:00
Fabio José 25e90caf43 🐛 Closes #67 - Maps the datacontenttype to content-type 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 10:12:01 -03:00
Fabio José 39427f3162 ✅ Test for kafka content type header mapping 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-11-21 10:06:16 -03:00
Fabio José d8fc237466 Fixing to camelCase 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-29 08:00:20 -03:00
Fabio José a635f429f8 Update examples to version 1.0 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 16:05:43 -03:00
Fabio José 84441cd0f9 Set version to 1.0.0 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 15:45:31 -03:00
Fabio José 313040f7f6 Kafka marshallers and unmarshallers 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 15:22:47 -03:00
Fabio José 43f779e010 Mapper for headers in kafka binding 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 15:20:18 -03:00
Fabio José 893ee567f0 Mapper for extension in kafka binding 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 15:17:44 -03:00
Fabio José 73f6c9572c Mapper for attributes in kafka binding 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-10-26 15:14:43 -03:00
Fabio José bf72800220 Set the release version to 0.3.1 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-30 13:34:45 -03:00
Fabio José b469da4388 Set the version 0.3.0 for release (without snapshot) 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-26 17:06:04 -03:00
Fabio José fda0e73429 Tests for kafka consumer 
Structured content mode

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-20 12:43:28 -03:00
Fabio José b14b6b0652 Adding imports in the examples docs 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-20 12:41:51 -03:00
Fabio José b7aa38eacb Kafka consumer tests 
Binary content mode

Spec 0.3

Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:05:04 -03:00
Fabio José efc32d5c09 Top-level unmarshallers for spec 0.3 
Signed-off-by: Fabio José <fabiojose@gmail.com>
 2019-09-19 23:04:25 -03:00
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