github
/
kafka-sink-azure-kusto
зеркало из
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность
270 коммитов 16 Ветки 14 Теги 654 KiB
Граф коммитов

270 Коммитов

Автор SHA1 Сообщение Дата
Anagha Khanolkar 5625ab0f90
Update README.md 2020-09-01 17:40:12 -05:00
Anagha Khanolkar 205fc12d62
Update README.md 2020-09-01 17:39:05 -05:00
Anagha Khanolkar af9d2fc1b9
Update README.md 2020-09-01 17:38:11 -05:00
Anagha Khanolkar 57ad6c492b
Update README.md 2020-09-01 17:37:40 -05:00
Anagha Khanolkar 75a703ba9d
Update README.md 2020-09-01 17:34:42 -05:00
Anagha Khanolkar 1bb8c008d8
Update README.md 2020-09-01 16:10:56 -05:00
Anagha Khanolkar 7f5fad8eb7
Update README.md 2020-09-01 16:10:26 -05:00
Anagha Khanolkar 2b5c19537e
Update README.md 2020-09-01 15:52:22 -05:00
Anagha Khanolkar 0fccdef47a
Update README.md 2020-09-01 15:50:02 -05:00
Anagha Khanolkar 6e30587ea0
Update README.md 2020-09-01 15:48:00 -05:00
Ohad Bitton 54a5c0f1e5 better timing on tests 2020-08-27 17:51:57 +03:00
Anagha Khanolkar 52f5e761b6
Update README.md 2020-08-27 09:27:30 -05:00
Fahad Sheikh 6e526fc563
adding back to maven build plugin for uber jar (#36) 
Co-authored-by: fahad <hasher@localhost>
 2020-08-17 13:26:41 +03:00
Fahad Sheikh 9d9e0c3cfa
Connect build fix (#35) 
* merged Azure/master

* Restructing project structure

* updated readme.md and pom.xml

* resolving PR comments

* removing unnecessary plugin

Co-authored-by: fahad <hasher@192.168.0.102>
Co-authored-by: fahad <hasher@localhost>
Co-authored-by: SanchayGupta1197 <sanchay.gupta@hashedin.com>
 2020-08-13 17:52:42 +03:00
ohad bitton 41f1513ea7
Precommit null check (#34) 
* null check

* shouldnt hide appId

Co-authored-by: Ohad Bitton <ohbitton@microsoft.com>
 2020-08-04 16:22:27 +03:00
Fahad Sheikh 51d8e34719
Precommit offset fix (#33) 
* merged Azure/master

* offset fix for preCommit()

Co-authored-by: fahad <hasher@192.168.0.102>
 2020-08-04 10:40:23 +03:00
Fahad Sheikh 1ca54a6d51
Error handling and DLQ support for IO operation failures. (#32) 
* added implementaion of Miscellaneous DLQ for TempDir

* resolved Pr changes

Co-authored-by: Fahad Sheikh <44108345+fahadhasher@users.noreply.github.com>

* resolved pr comments and updated relevant documentation

Co-authored-by: SanchayGupta1197 <sanchay.gupta@hashedin.com>
Co-authored-by: Sanchay Gupta <58803136+SanchayGupta1197@users.noreply.github.com>
 2020-07-21 10:58:24 +03:00
ohad bitton 6a979e9cfe
Merge pull request #31 from hashedin/avro-json-support 
Adding support for Avro and JSON formats with schema registry
 2020-07-16 16:02:40 +03:00
Fahad Sheikh 3c68d433fe
Merge pull request #17 from anmolbansal144/format-support 
renaming variables.
 2020-07-16 18:22:30 +05:30
hasher 439dc4be70 Merge branch 'format-support' of github.com:anmolbansal144/kafka-sink-azure-kusto into format-support 2020-07-16 18:11:03 +05:30
hasher 251f4307fe Rename kafkaProducer to dlqProducer 2020-07-16 18:07:21 +05:30
Fahad Sheikh eb23933216
Merge pull request #16 from SanchayGupta1197/file-permission-error-handling 
File permission error handling
 2020-07-16 16:05:07 +05:30
SanchayGupta1197 c40e948cbf removed handleerror form TopicPartitionWriter 2020-07-16 15:39:49 +05:30
Fahad Sheikh e405151122
Merge pull request #15 from anmolbansal144/format-support 
Updated outstream implementation, misc.deadletterqueue config and removed eventDataCompression
 2020-07-16 14:30:48 +05:30
SanchayGupta1197 ea1e0a5935 removed redundant test in FileWriterTest 2020-07-16 14:26:52 +05:30
SanchayGupta1197 476da15f15 resolve PR comments 2020-07-16 13:04:18 +05:30
SanchayGupta1197 38c9ed6865 Changing dlq. to misc.deadletterqueue. 2020-07-15 18:26:17 +05:30
hasher c5cc43cfed clean the code 2020-07-15 17:48:16 +05:30
hasher 767def4918 Removed event-data-compression 2020-07-15 17:44:43 +05:30
hasher 52ca6d06e0 clean the code 2020-07-15 16:58:25 +05:30
hasher c701f4141a removed unwanted import 2020-07-15 16:55:57 +05:30
hasher 715303d318 Refactored countingOutputStream 2020-07-15 16:47:51 +05:30
hasher 4bdaa588ca Added CountingOutputStream class 2020-07-15 16:21:20 +05:30
hasher ded2aaaadb Refactored raw bytes count logic 2020-07-15 15:46:05 +05:30
SanchayGupta1197 2d53ba3542 removed event copression data 2020-07-14 18:25:41 +05:30
hasher c990e58405 REsolve the pr comments and clean the code 2020-07-14 16:32:00 +05:30
SanchayGupta1197 95a4fbc7b0 Resolved PR changes 2020-07-13 16:13:06 +05:30
hasher a9b7544d6c Merge branch 'format-support' of github.com:anmolbansal144/kafka-sink-azure-kusto into format-support 2020-07-13 14:28:41 +05:30
hasher 6c1f87137c Remove \n from avro as bytes 2020-07-13 14:24:44 +05:30
SanchayGupta1197 b48a998998 resolve few PR comments 2020-07-10 17:34:14 +05:30
hasher f0e1edd94e clean pom and readme file 2020-07-10 13:20:25 +05:30
Fahad Sheikh 77fce2ac4e
Merge pull request #14 from anmolbansal144/final-build 
Adding support for Avro and JSON formats with schema registry
 2020-07-09 18:16:58 +05:30
hasher 0eab7fd166 clean AvroRecordWriterTest class 2020-07-09 18:14:28 +05:30
hasher 831882819b Improve exception handling 2020-07-09 16:32:22 +05:30
SanchayGupta1197 0b77fbc4bd resolving unwanted changes 2020-07-09 12:44:52 +05:30
SanchayGupta1197 7b1214d221 Removed connector docs 2020-07-09 11:50:28 +05:30
SanchayGupta1197 cf96c8e881 Added repository to pom.xml 2020-07-08 19:58:30 +05:30
ohad bitton d23cb417d1
Merge pull request #25 from hashedin/error-handling-dlq-retries 
Support for behavior.on.error, DLQ and Retries
 2020-07-08 15:46:25 +03:00
SanchayGupta1197 859f9381e5 resolved PR changes 2020-07-02 20:51:48 +05:30
SanchayGupta1197 f286ed493b added method to get custom DLQ properties 2020-07-02 18:54:42 +05:30