You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
We've been using Kafka triggers for a long time. We have never had to have a different environment-based parameterization for any of the enum values. Right now we need to have different ones for BrokerProtocol.
Development should be BrokerProtocol.SASLPLAINTEXT
while Production should be BrokerProtocol.SASLSSL
Brokers can be parameterized!
I'm not able to find any way to achieve that! Is there a way? which one -without having to refactor source code on build time a k a: code replacements-
To me seems very limiting not to be able to parameterize ALL OF THEM. Am I missing something?
Using a Constant Class defining
public static final BrokerProtocol BUILD_KAFKA_BROKERS_PROTOCOL_PLAIN=BrokerProtocol.SASLPLAINTEXT;
is neither an option in order to made code replacements -ugly- but in a centralized place
Thanks in advance
@KafkaTrigger(
name = String,
topic = String,
brokerList=String,
protocol=BrokerProtocol <---------------------------- NOT Parameretizable!
consumerGroup=String,
username=String,
password=String,
dataType=String,
authenticationMode=BrokerAuthenticationMode, <---------------------------- NOT Parameretizable!
cardinality=Cardinality, <---------------------------- NOT Parameretizable!
sslCertificateLocation=String,
sslCaLocation=String
)
The text was updated successfully, but these errors were encountered:
Does anybody have any work arounds for this? AuthenticationMode, and Protocol vary in our application across environments and trying to figure out how to get around this. Also, Dev envs have an empty value for Password, Username, SchemaRegistryUsername, and SchemaRegistryPassword which makes the library throw an error instead of just ignoring those settings.
Hello,
We've been using Kafka triggers for a long time. We have never had to have a different environment-based parameterization for any of the enum values. Right now we need to have different ones for BrokerProtocol.
Development should be BrokerProtocol.SASLPLAINTEXT
while Production should be BrokerProtocol.SASLSSL
Brokers can be parameterized!
I'm not able to find any way to achieve that! Is there a way? which one -without having to refactor source code on build time a k a: code replacements-
To me seems very limiting not to be able to parameterize ALL OF THEM. Am I missing something?
Using a Constant Class defining
public static final BrokerProtocol BUILD_KAFKA_BROKERS_PROTOCOL_PLAIN=BrokerProtocol.SASLPLAINTEXT;
is neither an option in order to made code replacements -ugly- but in a centralized place
Thanks in advance
@KafkaTrigger(
name = String,
topic = String,
brokerList=String,
protocol=BrokerProtocol <---------------------------- NOT Parameretizable!
consumerGroup=String,
username=String,
password=String,
dataType=String,
authenticationMode=BrokerAuthenticationMode, <---------------------------- NOT Parameretizable!
cardinality=Cardinality, <---------------------------- NOT Parameretizable!
sslCertificateLocation=String,
sslCaLocation=String
)
The text was updated successfully, but these errors were encountered: