GitHub user pwawrzyniak opened a pull request:
https://github.com/apache/incubator-samoa/pull/64
SAMOA-65 JSON serializer/deserializer dedicated for Kafka components
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pwawrzyniak/incubator-samoa SAMOA-65-JSON
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-samoa/pull/64.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 #64
----
commit 0e90fe8c107cd90a7baf16b5d4f334d1650a0afb
Author: pwawrzyniak <[email protected]>
Date: 2017-03-14T16:43:25Z
Initial structure of Kafka components.
Initital code for Kafka Consumer
commit 2168400f86189605b06fb531511235733bf3b6ca
Author: pwawrzyniak <[email protected]>
Date: 2017-03-17T10:05:14Z
Code for KafkaEntranceProcessor (consuming messages from Kafka)
commit cf2ff369989fa3560f1570dfaf32bcb746d51c25
Author: pwawrzyniak <[email protected]>
Date: 2017-03-17T10:54:47Z
Updated comments
commit 26d86da6ebdd53e440e8b1e65f5ba5ed9f5f609e
Author: pwawrzyniak <[email protected]>
Date: 2017-03-17T11:09:52Z
Sample serializer/deserializer for JSON and InstanceContentEvent
Updates in comments
commit 45b3546f9c525af385f646447a09d3683b70937d
Author: pwawrzyniak <[email protected]>
Date: 2017-03-17T14:40:25Z
KafkaDestinationProcessor implementation (sending msg to Kafka
commit 2e6d502a2909731cb9859ba3403407e6a33a2fc2
Author: pwawrzyniak <[email protected]>
Date: 2017-03-24T13:34:49Z
Tests for kafkaUtils and KafkaEntranceProcessor, minor changes in classes
commit 208febc0524ddc328ae1a785f0642650173f7101
Author: pwawrzyniak <[email protected]>
Date: 2017-04-11T14:44:30Z
Tests for KafkaDestinationProcessor, minor changes in classes
commit ff6b84dc5403c102388646a31f120c11ee416063
Author: Jakub Jankowski <[email protected]>
Date: 2017-04-28T15:08:29Z
Added Kafka Avro serializer with unit tests. Added Kafka task with unit test
commit 7997fd538c258e8844cbd1a81d4c6c43d8788aa4
Author: Jakub Jankowski <[email protected]>
Date: 2017-05-01T09:23:00Z
Merge branch 'SAMOA-65' of https://github.com/pwawrzyniak/incubator-samoa
into SAMOA-65
commit ae7889fce1f52afdaa6d7e6080cff54dd1b01b9b
Author: Jakub Jankowski <[email protected]>
Date: 2017-05-10T12:37:25Z
Fixing avro deserialization
commit 107c4c5f72fcacc38d02bfc7cd1552a1593cdd5a
Author: Jakub Jankowski <[email protected]>
Date: 2017-05-10T12:45:16Z
Fixing avro deserialization
commit cde0642ccc768f7492e8c5811b2f1232e58acec4
Author: pwawrzyniak <[email protected]>
Date: 2017-05-12T15:17:27Z
Rebuild of Consumer-related classes (added separate thread to read from
Kafka, blocking until sth received)
Major cleanup in tests
commit f20301a4c64c9487fdbcff17829b6a8018e9a00b
Author: pwawrzyniak <[email protected]>
Date: 2017-05-12T15:22:54Z
Minor change in tests
commit b4ee754c54ac5be51f9846704947e7c19c186e73
Author: Jakub Jankowski <[email protected]>
Date: 2017-05-16T12:11:36Z
Fixing avro deserializer (using ReflectDatumReader) to be able to read
arrays in InstanceData objects
commit d636ba90851d8424a6d3e651d80c87d0a8d7394e
Author: pwawrzyniak <[email protected]>
Date: 2017-05-16T13:00:33Z
Changes in JSON mapper
commit 57f80a5bf7d83c31d517a7d98741dd7457a4c84c
Author: pwawrzyniak <[email protected]>
Date: 2017-06-07T10:21:08Z
repo cleanup, split code into 3 branches
commit 04a28bb5ecbc039f07c17a91d57859c4651f56d9
Author: pwawrzyniak <[email protected]>
Date: 2017-06-07T10:50:15Z
JSON mapper with test
----
---
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.
---
