summary |
shortlog | log |
commit |
commitdiff |
tree
first ⋅ prev ⋅ next
Dan Smith [Tue, 1 Mar 2022 16:44:29 +0000 (08:44 -0800)]
GEODE-9925: Add LICENSE and NOTICE for binary (#18)
The kafka connector binary zip distribution includes apache geode and all it's
dependencies, some of which are not apache licensed. Creating a LICENSE and
NOTICE for the binary distribution, which are copied from Apache Geodes LICENSE
and NOTICE. Changing the build to include these files in the doc directory of
the binary distribution.
Nabarun Nag [Tue, 14 Dec 2021 18:34:50 +0000 (10:34 -0800)]
Upgrade dependencies (#17)
* log4j upgraded to 2.16.0
* Geode deps upgraded to 1.12.6
* surefire upgraded to 2.19.1
Ashish Choudhary [Fri, 15 Jan 2021 01:28:59 +0000 (06:58 +0530)]
Correcting grammar of the connector description (#13)
* correcting kafka spelling
* correcting grammar of description
M. Oleske [Sat, 5 Dec 2020 00:47:08 +0000 (16:47 -0800)]
Add a CI (#9)
* Create mvn-package-all-os.yml
* Latest is 20.04 not 18.04
apply spotless
Authored-by: M. Oleske <michael@oleske.engineer>
* Add license
Authored-by: M. Oleske <michael@oleske.engineer>
Ashish Choudhary [Mon, 30 Nov 2020 22:59:57 +0000 (04:29 +0530)]
Correcting Kafka spelling (#4)
Anthony Baker [Wed, 22 Apr 2020 15:32:31 +0000 (08:32 -0700)]
GEODE-8006 Add .asf.yaml to control notifications
Jason Huynh [Wed, 8 Apr 2020 01:03:23 +0000 (18:03 -0700)]
Added information about --max-message-count and increased default queue and batch sizes
Nabarun Nag [Fri, 3 Apr 2020 18:35:34 +0000 (11:35 -0700)]
Code improvements:
* Exceptions being thrown as ConnectException
* Return values are used.
* static analyzer recommendations are implemented.
Jason Huynh [Wed, 1 Apr 2020 16:31:58 +0000 (09:31 -0700)]
Added additional info logging if queue is full
Naburun Nag [Wed, 4 Mar 2020 01:46:36 +0000 (17:46 -0800)]
Debug logging added
Naburun Nag [Tue, 3 Mar 2020 22:30:56 +0000 (14:30 -0800)]
Added some logging statements.
Naburun Nag [Tue, 3 Mar 2020 22:05:09 +0000 (14:05 -0800)]
Adding recommenders
Naburun Nag [Tue, 3 Mar 2020 21:24:43 +0000 (13:24 -0800)]
Added validator and replaced use of booleans with enum
Naburun Nag [Tue, 3 Mar 2020 17:59:43 +0000 (09:59 -0800)]
Adding the version text file.
Naburun Nag [Tue, 3 Mar 2020 02:31:35 +0000 (18:31 -0800)]
Adding the versioning system for the connector.
Naburun Nag [Tue, 3 Mar 2020 01:49:04 +0000 (17:49 -0800)]
Using ConnectException
Naburun Nag [Tue, 3 Mar 2020 01:20:52 +0000 (17:20 -0800)]
Apache-rat integration.
Builds will fail if there is a file with missing license header.
Naburun Nag [Mon, 2 Mar 2020 22:16:01 +0000 (14:16 -0800)]
Spotless enabled
* check is as a part of the validate phase.
* license headers are inserted by spotless if not included in java files.
* All the setting files are same as used in the Geode project.
Naburun Nag [Mon, 2 Mar 2020 20:40:43 +0000 (12:40 -0800)]
Changing the Config definitions to include group, ordering, display name etc.
Jason Huynh [Mon, 2 Mar 2020 19:06:06 +0000 (11:06 -0800)]
moved cache creation errors to GeodeContext
added info logging
removed some debug logging
nabarunnag [Thu, 27 Feb 2020 22:29:39 +0000 (14:29 -0800)]
Removing gradle artifacts.
Naburun Nag [Wed, 26 Feb 2020 17:12:01 +0000 (09:12 -0800)]
Moved all string contansts to separate variables and classes
Naburun Nag [Tue, 25 Feb 2020 22:51:51 +0000 (14:51 -0800)]
Adding the configuration changes as per spec
Jason Huynh [Tue, 25 Feb 2020 22:44:25 +0000 (14:44 -0800)]
Update README.md
Jason Huynh [Tue, 25 Feb 2020 22:41:04 +0000 (14:41 -0800)]
Update README.md
Jason Huynh [Tue, 25 Feb 2020 22:40:39 +0000 (14:40 -0800)]
Update README.md
Jason Huynh [Tue, 25 Feb 2020 22:40:03 +0000 (14:40 -0800)]
Update README.md
Naburun Nag [Tue, 25 Feb 2020 19:24:33 +0000 (11:24 -0800)]
Fixed the logo file
Naburun Nag [Tue, 25 Feb 2020 19:01:00 +0000 (11:01 -0800)]
Changing the project to a maven project
Jason Huynh [Sat, 22 Feb 2020 00:21:36 +0000 (16:21 -0800)]
fixing path on default security auth init
Donal Evans [Fri, 21 Feb 2020 00:06:53 +0000 (16:06 -0800)]
Added JsonPdxConverter (#2)
- Allows PdxInstance objects to be converted to JSON bytes when sourced
from a Geode region into a Kafka topic
- Allows JSON bytes to be converted to PdxInstance objects when sinked
into a Geode region from a Kafka topic
- Added unit and DUnit tests for JsonPdxConverter
- Added functionality to the test framework to specify custom key
converter, custom value converter and configuration properties for each
- Added TestObject class to allow validation of
serialization/deserialization
Authored-by: Donal Evans <doevans@pivotal.io>
Jason Huynh [Thu, 20 Feb 2020 17:27:11 +0000 (09:27 -0800)]
Adding licensing header to fix rat issue
Naburun Nag [Wed, 19 Feb 2020 22:58:15 +0000 (14:58 -0800)]
Removed javadoc issues
Naburun Nag [Wed, 19 Feb 2020 22:45:58 +0000 (14:45 -0800)]
Removal of unused variables
Naburun Nag [Wed, 19 Feb 2020 22:33:09 +0000 (14:33 -0800)]
Static analyzer performance improvements.
Naburun Nag [Wed, 19 Feb 2020 22:27:57 +0000 (14:27 -0800)]
regEx improvements.
Naburun Nag [Wed, 19 Feb 2020 22:22:33 +0000 (14:22 -0800)]
Improved the regEx statements.
Naburun Nag [Wed, 19 Feb 2020 21:46:21 +0000 (13:46 -0800)]
Fixed spelling mistakes
Naburun Nag [Wed, 19 Feb 2020 21:18:37 +0000 (13:18 -0800)]
Static analyzer changes
Jason Huynh [Wed, 19 Feb 2020 19:01:44 +0000 (11:01 -0800)]
Update README.md
Naburun Nag [Wed, 19 Feb 2020 17:03:10 +0000 (09:03 -0800)]
Converting global variables to local
Nabarun Nag [Wed, 19 Feb 2020 04:39:10 +0000 (20:39 -0800)]
geode-dunit dependency added and naming changes
* Adding geode-dunit to run the tests.
* Adding the dunit folder to the gitignore
* adding the sink tests
* Fixing the sink test issue
* Renamed the package to org.apache
* Spotless and more apache renaming.
* Removed checked in
Jason Huynh [Fri, 14 Feb 2020 18:27:58 +0000 (10:27 -0800)]
Added SystemPropertyAuthInit Test
Removed unused test method
corrected spelling mistake
Jason Huynh [Thu, 13 Feb 2020 17:28:00 +0000 (09:28 -0800)]
All configurable parameters are now using '-' as delimiter instead of camelCase
Added documentation to the configDef definitions
Updated readme with latest configuration changes
Jason Huynh [Tue, 11 Feb 2020 21:13:17 +0000 (13:13 -0800)]
Modified initial results to consume the correct type
Modified security
Jason Huynh [Tue, 11 Feb 2020 18:42:46 +0000 (10:42 -0800)]
modified package of default system property auth init
Jason Huynh [Tue, 11 Feb 2020 06:28:50 +0000 (22:28 -0800)]
Modified to use ConfigDef and default values
bumped down the version to 1.9 for now
Added system property security auth init implementation that retries username and password from system properties
Naburun Nag [Mon, 10 Feb 2020 18:42:05 +0000 (10:42 -0800)]
Renaming the package name to org.apache.geode.kafka
Jason Huynh [Fri, 7 Feb 2020 00:40:56 +0000 (16:40 -0800)]
Adding sample property files
Jason Huynh [Fri, 7 Feb 2020 00:38:00 +0000 (16:38 -0800)]
Adding an AuthInitialize, just for example and readme sake
Jason Huynh [Thu, 6 Feb 2020 20:12:57 +0000 (12:12 -0800)]
Update README.md
Jason Huynh [Thu, 6 Feb 2020 20:03:43 +0000 (12:03 -0800)]
Added shadowJar task. To build uber jar just run ./gradlew shadowJar
Naburun Nag [Thu, 6 Feb 2020 19:21:11 +0000 (11:21 -0800)]
Addition of rat and spolessApply
* All offending files were also corrected.
Jason Huynh [Thu, 6 Feb 2020 19:10:20 +0000 (11:10 -0800)]
Update README.md
Jason Huynh [Tue, 4 Feb 2020 22:47:30 +0000 (14:47 -0800)]
Update README.md
Jason Huynh [Tue, 4 Feb 2020 22:31:51 +0000 (14:31 -0800)]
Configurable shared event buffer
Jason Huynh [Tue, 4 Feb 2020 21:35:30 +0000 (13:35 -0800)]
Fixed bug where tasks were sharing the same props
Modified source and sink tasks to share all region and topic bindings
Each source task is able to update kafka but only one will register for a specific region binding
Each sink task is able to update the appropriate Geode region
Jason Huynh [Sat, 1 Feb 2020 00:47:41 +0000 (16:47 -0800)]
Update README.md
Jason Huynh [Sat, 1 Feb 2020 00:45:07 +0000 (16:45 -0800)]
Update README.md
Jason Huynh [Sat, 1 Feb 2020 00:42:01 +0000 (16:42 -0800)]
Removed system outs
Passing through the security auth init property
Jason Huynh [Fri, 31 Jan 2020 00:31:11 +0000 (16:31 -0800)]
Added license headers to source and test files
Jason Huynh [Fri, 31 Jan 2020 00:26:31 +0000 (16:26 -0800)]
Update README.md
Jason Huynh [Fri, 31 Jan 2020 00:25:54 +0000 (16:25 -0800)]
Update README.md
Jason Huynh [Fri, 31 Jan 2020 00:23:31 +0000 (16:23 -0800)]
Update README.md
Jason Huynh [Fri, 31 Jan 2020 00:23:11 +0000 (16:23 -0800)]
Update README.md
Jason Huynh [Fri, 31 Jan 2020 00:10:13 +0000 (16:10 -0800)]
Added info to readme
Jason Huynh [Thu, 30 Jan 2020 22:43:03 +0000 (14:43 -0800)]
Seperated out Configuration into source and sink where appropriate
Added a few more tests
Naburun Nag [Thu, 30 Jan 2020 18:04:13 +0000 (10:04 -0800)]
Adding the idea folder to gitignore
Jason Huynh [Thu, 30 Jan 2020 00:49:40 +0000 (16:49 -0800)]
Adding missing classes
Jason Huynh [Thu, 30 Jan 2020 00:38:29 +0000 (16:38 -0800)]
Reworked region to topic and topic to region parsing
Tasks are assigned region to topic or topic to region groups
A task can handle multiple regions or multiple topics based on configuration
Jason Huynh [Tue, 28 Jan 2020 00:25:42 +0000 (16:25 -0800)]
Split regions and topics per task.
Jason Huynh [Sat, 25 Jan 2020 06:21:03 +0000 (22:21 -0800)]
Added loading entire region through initial results
Jason Huynh [Fri, 24 Jan 2020 00:43:49 +0000 (16:43 -0800)]
end to end tests use unique topic/regions, incase of cyclical/endless looping of events
Jason Huynh [Thu, 23 Jan 2020 23:43:11 +0000 (15:43 -0800)]
Added sink task and sink class
Added end to end sink test
Naburun Nag [Thu, 23 Jan 2020 18:34:57 +0000 (10:34 -0800)]
Adding a git ignore file
Jason Huynh [Thu, 23 Jan 2020 05:46:46 +0000 (21:46 -0800)]
added logger to classes
Removed system outs
Jason Huynh [Thu, 23 Jan 2020 05:36:32 +0000 (21:36 -0800)]
Added GeodeContext (for reals this time)
Added GeodeConnectorConfigTest
Jason Huynh [Thu, 23 Jan 2020 05:35:00 +0000 (21:35 -0800)]
Added GeodeContext to handle cache related operations
Added GeodeConnectorConfig for shared configs
Moved packages
Jason Huynh [Thu, 23 Jan 2020 02:57:35 +0000 (18:57 -0800)]
Changed all config to lower case
Changed to CqStatusListener instead of plain CqListener
Jason Huynh [Thu, 23 Jan 2020 01:33:38 +0000 (17:33 -0800)]
added missing files
Jason Huynh [Thu, 23 Jan 2020 01:32:25 +0000 (17:32 -0800)]
end to end test "passes" Not sure why we dont get all the events or don't get any events until enough polls are called
Jason Huynh [Fri, 17 Jan 2020 23:34:55 +0000 (15:34 -0800)]
geode as source to kafka hack test successful
Jason Huynh [Thu, 16 Jan 2020 17:30:10 +0000 (09:30 -0800)]
Worker and herder added
Source taskes being instantiated
Jason Huynh [Wed, 15 Jan 2020 23:10:24 +0000 (15:10 -0800)]
added log4j and able to stand up geode/kafka/zookeeper
Jason Huynh [Wed, 15 Jan 2020 01:01:52 +0000 (17:01 -0800)]
First cut of source and source task
Jason Huynh [Wed, 6 Nov 2019 01:22:24 +0000 (17:22 -0800)]
Initial commit