From 76e266f2c10a233f9cf2f5752755709a836cacbd Mon Sep 17 00:00:00 2001 From: Shay Bratslavsky Date: Mon, 26 Aug 2024 11:54:18 +0300 Subject: [PATCH] 3.5.1 beta (#180) * add github files * client config as one json (#166) * client config as one json * remove logic --------- Co-authored-by: Idan Asulin <74712806+idanasulin2706@users.noreply.github.com> * 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 <74712806+idanasulin2706@users.noreply.github.com> * 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 <74712806+idanasulin2706@users.noreply.github.com> * 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 <74712806+idanasulin2706@users.noreply.github.com> * 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 Co-authored-by: liranbahar Co-authored-by: Idan Asulin <74712806+idanasulin2706@users.noreply.github.com> Co-authored-by: Beka Kotchauri Co-authored-by: Beka Kotchauri <145648546+bkochauri-memphis@users.noreply.github.com> --- .../kafka/common/superstream/Superstream.java | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java b/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java index 34cc7abb..3eb2e1c1 100644 --- a/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java +++ b/clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java @@ -293,20 +293,6 @@ private Map populateConfigToSend(Map configs) { return configToSend; } - private Map populateConfigToSend(Map configs) { - Map configToSend = new HashMap<>(); - if (configs != null && !configs.isEmpty()) { - for (Map.Entry entry : configs.entrySet()) { - if (!Consts.superstreamConnectionKey.equalsIgnoreCase(entry.getKey())) { - configToSend.put(entry.getKey(), entry.getValue()); - } - } - - } - - return configToSend; - } - private void waitForStart() { CountDownLatch latch = new CountDownLatch(1); Dispatcher dispatcher = brokerConnection.createDispatcher((msg) -> {