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 <[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]>

clients/src/main/java/org/apache/kafka/common/superstream/Superstream.java

@@ -293,20 +293,6 @@ private Map<String, Object> populateConfigToSend(Map<String, ?> configs) {
         return configToSend;
     }
 
-    private Map<String, Object> populateConfigToSend(Map<String, ?> configs) {
-        Map<String, Object> configToSend = new HashMap<>();
-        if (configs != null && !configs.isEmpty()) {
-            for (Map.Entry<String, ?> 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) -> {