Added logic to check if a call to get cluster configuration is required prior to actually making the call.
This is to resolve an issue where my application does not have access to read cluster configuration but also doesn't have a need for it.
In my application, all the source topics exist and therefor it can read the partitions number from the topics rather than requiring the cluster configuration default partitions number.
Added logic to check if a call to get cluster configuration is required prior to actually making the call.
This is to resolve an issue where my application does not have access to read cluster configuration but also doesn't have a need for it. In my application, all the source topics exist and therefor it can read the partitions number from the topics rather than requiring the cluster configuration default partitions number.