зеркало из
1
0
Форкнуть 0
Граф коммитов

270 Коммитов

Автор SHA1 Сообщение Дата
SanchayGupta1197 f7179645b8 Refactored table, table mapping and access validation 2020-07-02 13:08:30 +05:30
hasher c6335cf9ae change log to exception in isDlqEnabledMethod 2020-06-30 22:13:42 +05:30
hasher ef84b9df4c Refactored kafka-producer code 2020-06-30 21:59:04 +05:30
hasher 560cebaacc clean the code 2020-06-30 17:06:44 +05:30
hasher c10245d1d5 Add validation whether table is access or not 2020-06-30 16:15:12 +05:30
hasher 79b4e0a89d Refactor flush logic for avro as byte 2020-06-30 12:19:46 +05:30
hasher 9e5f495748 Remove extra bracket from shouldWriteAvroAsBytes method 2020-06-29 20:46:30 +05:30
hasher 64578e2226 add flush check for avro as byte 2020-06-29 20:35:50 +05:30
hasher 354b4514c5 change log level of Avro and Json RecordWriter 2020-06-29 18:52:38 +05:30
hasher 7337ec7704 Refactored the code 2020-06-29 17:53:59 +05:30
hasher 10a722c165 Fix the indentation 2020-06-29 15:36:34 +05:30
hasher a17e59fcaf clean the code 2020-06-29 14:58:46 +05:30
hasher d9ded15aa9 Remove unwanted code 2020-06-29 14:40:55 +05:30
hasher 839260fb98 pull latest code and sync it 2020-06-29 14:33:21 +05:30
fahad 81c61d2d23 remove unused imports 2020-06-26 17:56:26 +05:30
fahad 40d4dfbac7 tempdir delete @connector.close 2020-06-26 17:54:51 +05:30
fahad 0e9772ca10 Common temp dir for Connector tasks 2020-06-26 17:23:42 +05:30
Fahad Sheikh 1fadd5ce13
Merge pull request #11 from SanchayGupta1197/error-handling-dlq-retries
delete tmp directory
2020-06-26 00:05:53 +05:30
Sanchay Gupta fe6f730b4d
resolved review commits
Co-authored-by: Fahad Sheikh <44108345+fahadhasher@users.noreply.github.com>
2020-06-26 00:05:03 +05:30
SanchayGupta1197 ea21c11ed9 Connecter task subdirectory 2020-06-25 23:54:35 +05:30
fahad 4667c071ef nit: indentation 2020-06-25 22:11:48 +05:30
fahad 86c62f246f fix unit tests 2020-06-25 21:38:54 +05:30
fahad f81d7be15c remove deprecated configs | add tmp-dir 2020-06-25 20:37:04 +05:30
fahad 3e51ea88fe javadoc nit 2020-06-25 17:55:45 +05:30
Fahad Sheikh 071a4ac8cf
Merge pull request #10 from SanchayGupta1197/PR25-test-refactor
Refactored tests
2020-06-25 17:50:57 +05:30
SanchayGupta1197 e0090a79e0 Refactored tests 2020-06-25 17:29:16 +05:30
fahad f4f97ccb55 resolved pr comments 2020-06-25 15:47:03 +05:30
hasher 878e127780 change message of connect exception in initializeRecordWriter method 2020-06-23 20:51:37 +05:30
hasher 5c266224ac Resolve pr comments 2020-06-23 19:31:47 +05:30
hasher 53a07da072 Remove unwanted code and clean the code 2020-06-23 13:04:06 +05:30
fahad 6ec7e60e76 rename test 2020-06-22 22:02:57 +05:30
fahad bb30c7cf2f removed auth.user, auth.pass support | changed aad configs to mandatory 2020-06-22 21:49:19 +05:30
hasher caba9d4e82 clean the code and remove unwanted changes 2020-06-22 21:19:34 +05:30
fahad 744f34c88d configs updated in README 2020-06-22 20:30:03 +05:30
fahad 6d081fc062 minor doc correction in readme 2020-06-22 20:27:40 +05:30
fahad c371c7647d doc improvements 2020-06-22 20:26:01 +05:30
fahad f73579d75c Fixed unit and E2E tests 2020-06-21 21:50:05 +05:30
fahad e1d51cb195 resolve merge conflicts | fix for missing dlq recods 2020-06-21 21:11:19 +05:30
hasher 1b02308297 clean the code 2020-06-21 16:01:24 +05:30
hasher 696f63f37c Added struct support for json 2020-06-21 15:42:40 +05:30
hasher ea6417f7a9 Added different formatters and integeration test 2020-06-19 21:39:19 +05:30
ohad bitton 938873e780
Merge pull request #29 from gholliday/gholliday/fixes
Fixes for temp directory null error and kusto.auth.authority not found
2020-06-19 18:38:43 +03:00
ohad bitton 03a9d6d994
Merge branch 'master' into gholliday/fixes 2020-06-19 18:38:32 +03:00
ohad bitton cb3c4b9517
Fix config 2020-06-19 12:07:06 +03:00
Fahad Sheikh 40c1b3d8db
Merge pull request #7 from SanchayGupta1197/error-handling-dlq-kusto-sdk-upgrade
Updated Kusto SDK version from 1.4.2 to 2.1.0
2020-06-18 14:49:58 +05:30
SanchayGupta1197 44f6a698c4 Changed error message for DataServiceException 2020-06-18 14:47:13 +05:30
SanchayGupta1197 f787444b89 Updated Kusto SDK version from 1.4.2 to 2.1.0 2020-06-18 14:25:32 +05:30
fahad 9c1f74f777 changing errorTolerance -> BehaviorOnError 2020-06-18 14:23:03 +05:30
fahad 8b68c2af84 connectexception when retries fail 2020-06-18 13:27:43 +05:30
fahad ab7d88c97f handling service exception for retries 2020-06-18 13:13:49 +05:30