97f07a296ae39e263a336e26e7ee60175b27d5d7
[dcaegen2/services/sdk.git] /
1 /*
2  * ============LICENSE_START====================================
3  * DCAEGEN2-SERVICES-SDK
4  * =========================================================
5  * Copyright (C) 2019 Nokia. All rights reserved.
6  * =========================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *       http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=====================================
19  */
20
21 package org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.dmaap;
22
23 import org.immutables.value.Value;
24 import org.jetbrains.annotations.Nullable;
25 import org.onap.dcaegen2.services.sdk.rest.services.annotations.ExperimentalApi;
26 import org.onap.dcaegen2.services.sdk.rest.services.cbs.client.model.streams.AafCredentials;
27
28 /**
29  * @author <a href="mailto:piotr.jaszczyk@nokia.com">Piotr Jaszczyk</a>
30  * @since 1.1.4
31  */
32 @ExperimentalApi
33 public interface Kafka {
34
35     String bootstrapServers();
36
37     String topicName();
38
39     @Nullable AafCredentials aafCredentials();
40
41     @Nullable String clientRole();
42
43     @Nullable String clientId();
44
45     @Value.Default
46     default int maxPayloadSizeBytes() {
47         return 1024 * 1024;
48     }
49 }