2 * Copyright © 2019 IBM.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.onap.ccsdk.cds.blueprintsprocessor.message
19 /** Producer Properties **/
20 open class MessageProducerProperties
23 open class KafkaBasicAuthMessageProducerProperties : MessageProducerProperties() {
24 lateinit var bootstrapServers: String
25 var topic: String? = null
26 var clientId: String? = null
29 /** Consumer Properties **/
31 open class MessageConsumerProperties
33 open class KafkaMessageConsumerProperties : MessageConsumerProperties() {
34 lateinit var bootstrapServers: String
35 lateinit var groupId: String
36 var clientId: String? = null
37 var topic: String? = null
38 var pollMillSec: Long = 1000
41 open class KafkaBasicAuthMessageConsumerProperties : KafkaMessageConsumerProperties()