summaryrefslogtreecommitdiffstats
path: root/src/main/config
diff options
context:
space:
mode:
authorVarun Gudisena <vg411h@att.com>2017-08-30 11:34:48 -0500
committerVarun Gudisena <vg411h@att.com>2017-08-30 11:35:00 -0500
commit2b4d7eb39b0ceb182467d564ab457a61ce873ed3 (patch)
treee7bcd0ad2b73d4598e8471940e97d0c01993c11e /src/main/config
parentf5c12be64c403ae0b1b816e97b064d28479faac3 (diff)
ADD Initial Code Import
Added initial code for mirror agent Issue-id: DMAAP-76 Change-Id: I8b4521706c4f3a96720987fb75b5b8d5cfd05ec3 Signed-off-by: Varun Gudisena <vg411h@att.com>
Diffstat (limited to 'src/main/config')
-rw-r--r--src/main/config/consumer.properties50
-rw-r--r--src/main/config/mmagent.config7
-rw-r--r--src/main/config/mmagent.config_old5
-rw-r--r--src/main/config/producer.properties74
-rw-r--r--src/main/config/template.lrm.xml142
5 files changed, 278 insertions, 0 deletions
diff --git a/src/main/config/consumer.properties b/src/main/config/consumer.properties
new file mode 100644
index 0000000..08d29af
--- /dev/null
+++ b/src/main/config/consumer.properties
@@ -0,0 +1,50 @@
+###############################################################################
+# ============LICENSE_START=======================================================
+# org.onap.dmaap
+# ================================================================================
+# Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+###############################################################################
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# see kafka.consumer.ConsumerConfig for more details
+
+# Zookeeper connection string
+# comma separated host:port pairs, each corresponding to a zk
+# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002"
+zookeeper.connect=172.18.0.1:2181
+
+# timeout in ms for connecting to zookeeper
+zookeeper.connection.timeout.ms=6000
+
+#consumer group id
+group.id=test-consumer-group
+
+#consumer timeout
+#consumer.timeout.ms=5000
diff --git a/src/main/config/mmagent.config b/src/main/config/mmagent.config
new file mode 100644
index 0000000..9e43eae
--- /dev/null
+++ b/src/main/config/mmagent.config
@@ -0,0 +1,7 @@
+#kafkahome=C:/dev/att/kafka_2.10-0.8.2.1
+kafkahome=/opt/
+topicURL=http://172.18.0.1:3904
+#topicname=org.onap.dmaap.messagerouter.mirroragent.agenttest
+topicname=org.openecomp.dmaapBC.mmatopic
+mechid=dgl@openecomp.org
+password=ecomp_admin \ No newline at end of file
diff --git a/src/main/config/mmagent.config_old b/src/main/config/mmagent.config_old
new file mode 100644
index 0000000..a0b80df
--- /dev/null
+++ b/src/main/config/mmagent.config_old
@@ -0,0 +1,5 @@
+kafkahome=/opt/app/dmaap/msgrtr/kafka
+topicURL=http://<mr_host>:3904
+topicname=org.onap.dmaap.messagerouter.mirroragent.agenttest
+mechid=<aaf_id>
+password=<aaf_password> \ No newline at end of file
diff --git a/src/main/config/producer.properties b/src/main/config/producer.properties
new file mode 100644
index 0000000..30df665
--- /dev/null
+++ b/src/main/config/producer.properties
@@ -0,0 +1,74 @@
+###############################################################################
+# ============LICENSE_START=======================================================
+# org.onap.dmaap
+# ================================================================================
+# Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+# ================================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+#
+###############################################################################
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License. You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# see kafka.producer.ProducerConfig for more details
+
+############################# Producer Basics #############################
+
+# list of brokers used for bootstrapping knowledge about the rest of the cluster
+# format: host1:port1,host2:port2 ...
+metadata.broker.list=104.130.132.211:9092
+
+# name of the partitioner class for partitioning events; default partition spreads data randomly
+#partitioner.class=
+
+# specifies whether the messages are sent asynchronously (async) or synchronously (sync)
+producer.type=sync
+
+# specify the compression codec for all data generated: none, gzip, snappy, lz4.
+# the old config values work as well: 0, 1, 2, 3 for none, gzip, snappy, lz4, respectively
+compression.codec=none
+
+# message encoder
+serializer.class=kafka.serializer.DefaultEncoder
+
+# allow topic level compression
+#compressed.topics=
+
+############################# Async Producer #############################
+# maximum time, in milliseconds, for buffering data on the producer queue
+#queue.buffering.max.ms=
+
+# the maximum size of the blocking queue for buffering on the producer
+#queue.buffering.max.messages=
+
+# Timeout for event enqueue:
+# 0: events will be enqueued immediately or dropped if the queue is full
+# -ve: enqueue will block indefinitely if the queue is full
+# +ve: enqueue will block up to this many milliseconds if the queue is full
+#queue.enqueue.timeout.ms=
+
+# the number of messages batched at the producer
+#batch.num.messages=
diff --git a/src/main/config/template.lrm.xml b/src/main/config/template.lrm.xml
new file mode 100644
index 0000000..a36cf2c
--- /dev/null
+++ b/src/main/config/template.lrm.xml
@@ -0,0 +1,142 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<!--
+ ============LICENSE_START=======================================================
+ org.onap.dmaap
+ ================================================================================
+ Copyright © 2017 AT&T Intellectual Property. All rights reserved.
+ ================================================================================
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+ ============LICENSE_END=========================================================
+
+ ECOMP is a trademark and service mark of AT&T Intellectual Property.
+
+ -->
+
+<ns2:ManagedResourceList xmlns="http://scld.att.com/lrm/commontypes"
+ xmlns:ns2="http://scld.att.com/lrm/util" xmlns:ns3="http://scld.att.com/lrm/types">
+ <ns2:ManagedResource>
+ <ResourceDescriptor>
+ <ResourceName>__SOA_CLOUD_NAMESPACE__.${artifactId}</ResourceName>
+ <ResourceVersion>
+ <Major>__MAJOR_VERSION__</Major>
+ <Minor>__MINOR_VERSION__</Minor>
+ <Patch>__PATCH_VERSION__</Patch>
+ </ResourceVersion>
+
+ </ResourceDescriptor>
+ <ResourceType>Java</ResourceType>
+ <ResourceContainerType></ResourceContainerType>
+ <ResourceContainerTypeVendor>ATT</ResourceContainerTypeVendor>
+ <ResourcePath>/opt/app/dmaap/mmagent</ResourcePath>
+ <ResourceProps>
+ <Tag>process.path</Tag>
+ <Value>/usr/bin:/usr/sbin:${PATH}</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>process.workdir</Tag>
+ <Value>/opt/app/dmaap/mmagent</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>process.libpath</Tag>
+ <Value>${LD_LIBRARY_PATH}</Value>
+ </ResourceProps>
+
+ <!-- The following process.args are for your context, port, and sslport.
+ NOTE: The "context" argument will set your context. context=/ will run your service under a "root" context.
+ Port selection is NOT necessary and should NOT be hardcoded if you are choosing to utilize ephemeral ports.
+ If NO port values are given, the AJSC will default to running on ephemeral ports (for both your http port
+ AND your https port), and your port will be selected for you. -->
+
+ <!-- Add JMX port -->
+
+ <ResourceProps>
+ <Tag>jmx.port</Tag>
+ <Value>__JMX_PORT_MRAGENT__</Value>
+ </ResourceProps>
+
+
+ <!-- End -->
+
+ <ResourceProps>
+ <Tag>jvm.version</Tag>
+ <Value>__JAVA_VERSION__</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>jvm.classpath</Tag>
+ <Value>:.:${CLASSPATH}:/opt/app/dmaap/mmagent/etc:/opt/app/dmaap/mmagent/lib/*:</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>jvm.args.pre</Tag>
+ <Value>__PRE_JVM_ARGS__ -XX:MaxPermSize=__MAX_PERM_SIZE__
+ -XX:PermSize=__PERM_SIZE__
+ __INTROSCOPE_VARS__
+ -Djava.net.preferIPv4Stack=true
+ -DMMAGENTHOME=/opt/app/dmaap/mmagent
+ __POST_JVM_ARGS__
+ __SCLD_OPTIONAL_PLATFORM_FLAG__
+ -DMMAGENTHOME=/opt/app/dmaap/mmagent
+ </Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>jvm.heap.min</Tag>
+ <Value>__MIN_HEAP_SIZE__</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>jvm.heap.max</Tag>
+ <Value>__MAX_HEAP_SIZE__</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>start.class</Tag>
+ <Value>org.onap.dmaap.messagerouter.mirroragent.nsa.dmaapMMAgent.MirrorMakerAgent</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>stdout.redirect</Tag>
+ <Value>log/stdout.log</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>stderr.redirect</Tag>
+ <Value>log/stdout.log</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>validatePID.waitime.seconds</Tag>
+ <Value>__LRM_VALIDATEPID_WAITTIME_SECONDS__</Value>
+ </ResourceProps>
+ <ResourceProps>
+ <Tag>mbean.name</Tag>
+
+ <Value>JmxInterface:type=DME2</Value>
+ </ResourceProps>
+ <ResourceOSID>msgrtr</ResourceOSID>
+ <ResourceStartType>__LRM_RESOURCE_START_TYPE__</ResourceStartType>
+ <ResourceStartPriority>__LRM_START_PRIORITY__</ResourceStartPriority>
+ <ResourceStartTimeout>__LRM_START_TIMEOUT__</ResourceStartTimeout>
+ <ResourceMinCount>__RESOURCE_MIN_COUNT__</ResourceMinCount>
+ <ResourceMaxCount>__RESOURCE_MAX_COUNT__</ResourceMaxCount>
+ <ResourceMaxRestart>__LRM_RESOURCE_MAX_RESTART__</ResourceMaxRestart>
+ <ResourceHeartBeat>__LRM_RESOURCE_HEARTBEAT__</ResourceHeartBeat>
+ <ResourceHeartBeatFailedLimit>__LRM_RESOURCE_HEARTBEAT_FAILED_LIMIT__</ResourceHeartBeatFailedLimit>
+ <ResourceHeartBeatTimeout>__LRM_RESOURCE_HEARTBEAT_TIMEOUT__</ResourceHeartBeatTimeout>
+ <ResourceShutdownWaitTimeInSecs>__RESOURCE_MANAGER_WAIT_TIME_IN_SECONDS__</ResourceShutdownWaitTimeInSecs>
+ <ResourceRegistration>__LRM_RESOURCE_REGISTRATION__</ResourceRegistration>
+ <GroupName>dmaap</GroupName>
+ <ResourceErrorNotify>
+ <NotifyListEntry>
+ <Loglevel>WARNING</Loglevel>
+ <EmailList>__CLDLRM_WARNING_NOTIFY__</EmailList>
+ </NotifyListEntry>
+ <NotifyListEntry>
+ <Loglevel>SEVERE</Loglevel>
+ <EmailList>__CLDLRM_SEVERE_NOTIFY__</EmailList>
+ </NotifyListEntry>
+ </ResourceErrorNotify>
+ </ns2:ManagedResource>
+</ns2:ManagedResourceList>