added SUPERSTREAM_DEBUG env var handle- disable and able all stdout #173
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
shay23b
suggested changes
Aug 20, 2024
clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java
Show resolved
Hide resolved
| } | ||
| } | ||
|
|
||
| private static String getSuperstreamClientInterceptorName(String type) { |
There was a problem hiding this comment.
there is also serializer/deserializer logic here
Move comments to empty method related to it
There was a problem hiding this comment.
it was in comment before. I just took it out into a method. do you want to uncomment the logic inside ?
|
|
||
| public static final String PRODUCER = "producer"; | ||
| public static final String CONSUMER = "consumer"; | ||
| //env vars |
There was a problem hiding this comment.
remove comment, add it to the name for example SUPERSTREAM_COMPRESSION_ENABLED -> SUPERSTREAM_COMPRESSION_ENABLED_ENV_VAR
There was a problem hiding this comment.
will be modified
shay23b
approved these changes
Aug 21, 2024
shay23b
approved these changes
Aug 21, 2024
shay23b
added a commit
that referenced
this pull request
Aug 26, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
shay23b
added a commit
that referenced
this pull request
Aug 26, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE * remove unnessecary method (#179) --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
shay23b
added a commit
that referenced
this pull request
Sep 10, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE * remove unnessecary method (#179) * SuperstreamObjectMapper for full config map to bytes (#182) * SuperstreamObjectMapper for full config map to bytes * SuperstreamObjectMapper for full config map to bytes small fix * mapper change * mapper testing problematic entry * mapper testing different approach * mapper testing different approach 2 * version beta upgrade * clean imports * versions upgrade --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
shay23b
added a commit
that referenced
this pull request
Sep 12, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE * remove unnessecary method (#179) * SuperstreamObjectMapper for full config map to bytes (#182) * SuperstreamObjectMapper for full config map to bytes * SuperstreamObjectMapper for full config map to bytes small fix * mapper change * mapper testing problematic entry * mapper testing different approach * mapper testing different approach 2 * version beta upgrade * clean imports * versions upgrade * SUPERSTREAM_DEBUG - default is false - will not see logs (#184) --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
shay23b
added a commit
that referenced
this pull request
Sep 15, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE * remove unnessecary method (#179) * SuperstreamObjectMapper for full config map to bytes (#182) * SuperstreamObjectMapper for full config map to bytes * SuperstreamObjectMapper for full config map to bytes small fix * mapper change * mapper testing problematic entry * mapper testing different approach * mapper testing different approach 2 * version beta upgrade * clean imports * versions upgrade * SUPERSTREAM_DEBUG - default is false - will not see logs (#184) * Fix client config update (#187) * fix client config update + add deep copy * fix null fullClientConfigs * pr template --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
nikola-nedic-sa
pushed a commit
that referenced
this pull request
Oct 15, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
nikola-nedic-sa
pushed a commit
that referenced
this pull request
Oct 15, 2024
* add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <[email protected]> * test fat jar * fix branch * add plugin * add archive option * fix serve file * fix * test app * fix * fix * Rnd 759 client parameters to store (#168) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config --------- Co-authored-by: Idan Asulin <[email protected]> * Rnd 759 client parameters to store (#169) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 --------- Co-authored-by: Idan Asulin <[email protected]> * revert none relevant changes into Jenkinsfile * remove none relevant comments * Rnd 759 client parameters to store (#172) * client config as one json * remove logic * remove superstream connection entry from configToSend * update version beta file * fix * remove comments * remove imports * support update full config for client * change the versions and pass client ip and host * handle consumer full config update * handle consumer full config update * gradle_build_imports * handle admin client update full config * back to 113 * buildNewGradle * wait mechanism for canstart * synchronized the other thread * wait mechanism refactor * remove comment * beta version upgrade --------- Co-authored-by: Idan Asulin <[email protected]> * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout (#173) * added SUPERSTREAM_DEBUG env var handle- disable and able all stdout * version beta * version beta --> 3 * refactor with consts for initSuperstreamConfig method * change SUPERSTREAM_DEBUG env var affect only for superstream stdout * log for test * revert test log * change consts env var names * revert partitions.contains * serielizer/desirielizer handle for payload reduction. empty methods * revert contains check * stdout handle outside of superstream class * changed superstream connection log in adnminKafka * move log for Successfully connection to superstream after waitForStart * move it again * Rnd 955 support in changing client config parameters (#174) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * Rnd 955 support in changing client config parameters (#175) * mechnisim of wait for superstream config and config bootstrap servers remove for test * move place for test * add getter to abstract config values. remove the bootstrap servers key-val * set the superstream config vaues inside kafka producer config * wait for super stream config move to super stream class, wait with object lock to support release cpu in wait interval * refactor for waiting methods * default timeout for superstream config * move getter location * list of supported client added in consts- we register clients only if type in the list * to lower case added * move type check to the AbstractConfig * move import * upgrade beta version-beta.conf * fix stdout when superstream failed initializing * upgrade version beta * remove_pr_template (#176) * Remove pr template (#177) * remove_pr_template * move PULL_REQUEST_TEMPLATE * remove unnessecary method (#179) --------- Co-authored-by: idanasulinStrech <[email protected]> Co-authored-by: liranbahar <[email protected]> Co-authored-by: Idan Asulin <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]> Co-authored-by: Beka Kotchauri <[email protected]>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.
Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.
Committer Checklist (excluded from commit message)