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
# consumer URL, should be in one line, for readability added new lines
kafka.url=kafka://
${kafka.topic}?
brokers=${kafka.broker}&&groupId=${kafka.groupId}
serializerClass=org.apache.kafka.common.serialization.StringSerializer&
keySerializerClass=org.apache.kafka.common.serialization.StringSerializer&
securityProtocol=${securityProtocol}&
sslKeystoreLocation=${keystore-path}&
sslKeystorePassword=${keystore-password}&
sslTruststoreLocation=${trust-store-path}&
sslTruststorePassword=${secrete-password-for-truststore}# if you do not need to verify brocker url has https or not then need to add following property along with other
sslEndpointAlgorithm=null
# If the option is true, then KafkaProducer will ignore the KafkaConstants.TOPIC header setting of the inbound message.# if your old topics have messages with headers like exchange.getIn().setHeader(KafkaConstants.PARTITION_KEY, "myKey");
# then you need to set following property for producer# producer url
bridgeEndpoint=true
# Pattern:
kafka://<topic>? brokers=<brokers># if multiple topics, add it as comma separated
topic1,topic2,topic3