Repository: ambari Updated Branches: refs/heads/trunk 96d3afe02 -> 10e4d1cd5
http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/common-services/KAFKA/0.9.0/widgets.json ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.9.0/widgets.json b/ambari-server/src/main/resources/common-services/KAFKA/0.9.0/widgets.json new file mode 100644 index 0000000..7237236 --- /dev/null +++ b/ambari-server/src/main/resources/common-services/KAFKA/0.9.0/widgets.json @@ -0,0 +1,182 @@ +{ + "layouts": [ + { + "layout_name": "default_kafka_dashboard", + "display_name": "Standard Kafka Dashboard", + "section_name": "KAFKA_SUMMARY", + "widgetLayoutInfo": [ + { + "widget_name": "Broker Topics", + "description": "Broker Topics", + "widget_type": "GRAPH", + "is_visible": true, + "metrics": [ + { + "name": "kafka.server.BrokerTopicMetrics.BytesInPerSec.1MinuteRate", + "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/1MinuteRate", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + }, + { + "name": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate", + "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/1MinuteRate", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + }, + { + "name": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.1MinuteRate", + "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/1MinuteRate", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + } + ], + "values": [ + { + "name": "Bytes In", + "value": "${kafka.server.BrokerTopicMetrics.BytesInPerSec.1MinuteRate}" + }, + { + "name": "Bytes Out", + "value": "${kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate}" + }, + { + "name": "Messages In", + "value": "${kafka.server.BrokerTopicMetrics.MessagesInPerSec.1MinuteRate}" + } + ], + "properties": { + "graph_type": "LINE", + "time_range": "1" + } + }, + { + "widget_name": "Active Controller Count", + "description": "Active Controller Count", + "widget_type": "GRAPH", + "is_visible": true, + "metrics": [ + { + "name": "kafka.controller.KafkaController.ActiveControllerCount", + "metric_path": "metrics/kafka/controller/KafkaController/ActiveControllerCount", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + } + ], + "values": [ + { + "name": "Active Controller Count", + "value": "${kafka.controller.KafkaController.ActiveControllerCount}" + } + ], + "properties": { + "graph_type": "LINE", + "time_range": "1" + } + }, + { + "widget_name": "Controller Status", + "description": "Controller Status", + "widget_type": "GRAPH", + "is_visible": true, + "metrics": [ + { + "name": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.1MinuteRate", + "metric_path": "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/1MinuteRate", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + }, + { + "name": "kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.1MinuteRate", + "metric_path": "metrics/kafka/controller/ControllerStats/UncleanLeaderElectionsPerSec/1MinuteRate", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + } + ], + "values": [ + { + "name": "Leader Election Rate And Time", + "value": "${kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.1MinuteRate}" + }, + { + "name": "Unclean Leader Election", + "value": "${kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.1MinuteRate}" + } + ], + "properties": { + "graph_type": "LINE", + "time_range": "1" + } + }, + { + "widget_name": "Replica MaxLag", + "description": "Replica MaxLag", + "widget_type": "GRAPH", + "is_visible": true, + "metrics": [ + { + "name": "kafka.server.ReplicaFetcherManager.MaxLag.clientId.Replica", + "metric_path": "metrics/kafka/server/ReplicaFetcherManager/Replica-MaxLag", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + } + ], + "values": [ + { + "name": "Replica MaxLag", + "value": "${kafka.server.ReplicaFetcherManager.MaxLag.clientId.Replica}" + } + ], + "properties": { + "graph_type": "LINE", + "time_range": "1" + } + }, + { + "widget_name": "Replica Manager", + "description": "Replica Manager", + "widget_type": "GRAPH", + "is_visible": true, + "metrics": [ + { + "name": "kafka.server.ReplicaManager.PartitionCount", + "metric_path": "metrics/kafka/server/ReplicaManager/PartitionCount", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + }, + { + "name": "kafka.server.ReplicaManager.UnderReplicatedPartitions", + "metric_path": "metrics/kafka/server/ReplicaManager/UnderReplicatedPartitions", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + }, + { + "name": "kafka.server.ReplicaManager.LeaderCount", + "metric_path": "metrics/kafka/server/ReplicaManager/LeaderCount", + "service_name": "KAFKA", + "component_name": "KAFKA_BROKER" + } + ], + "values": [ + { + "name": "Partitions count", + "value": "${kafka.server.ReplicaManager.PartitionCount}" + }, + { + "name": "Under Replicated Partitions", + "value": "${kafka.server.ReplicaManager.UnderReplicatedPartitions}" + }, + { + "name": "Leader Count", + "value": "${kafka.server.ReplicaManager.LeaderCount}" + } + ], + "properties": { + "graph_type": "LINE", + "time_range": "1" + } + } + + ] + } + ] +} http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.2/services/KAFKA/metainfo.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.2/services/KAFKA/metainfo.xml b/ambari-server/src/main/resources/stacks/HDP/2.2/services/KAFKA/metainfo.xml index ba530e9..24d93e7 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.2/services/KAFKA/metainfo.xml +++ b/ambari-server/src/main/resources/stacks/HDP/2.2/services/KAFKA/metainfo.xml @@ -20,25 +20,8 @@ <services> <service> <name>KAFKA</name> - <extends>common-services/KAFKA/0.8.1.2.2</extends> - <osSpecifics> - <osSpecific> - <osFamily>redhat7,amazon2015,redhat6,suse11,suse12</osFamily> - <packages> - <package> - <name>kafka_${stack_version}</name> - </package> - </packages> - </osSpecific> - <osSpecific> - <osFamily>debian7,ubuntu12,ubuntu14</osFamily> - <packages> - <package> - <name>kafka-${stack_version}</name> - </package> - </packages> - </osSpecific> - </osSpecifics> + <version>0.8.1.2.2</version> + <extends>common-services/KAFKA/0.8.1</extends> </service> </services> </metainfo> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/alerts.json ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/alerts.json b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/alerts.json deleted file mode 100644 index 04fb583..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/alerts.json +++ /dev/null @@ -1,32 +0,0 @@ -{ - "KAFKA": { - "service": [], - "KAFKA_BROKER": [ - { - "name": "kafka_broker_process", - "label": "Kafka Broker Process", - "description": "This host-level alert is triggered if the Kafka Broker cannot be determined to be up.", - "interval": 1, - "scope": "HOST", - "source": { - "type": "PORT", - "uri": "{{kafka-broker/listeners}}", - "default_port": 6667, - "reporting": { - "ok": { - "text": "TCP OK - {0:.3f}s response on port {1}" - }, - "warning": { - "text": "TCP OK - {0:.3f}s response on port {1}", - "value": 1.5 - }, - "critical": { - "text": "Connection failed: {0} to {1}:{2}", - "value": 5.0 - } - } - } - } - ] - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-broker.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-broker.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-broker.xml deleted file mode 100644 index 8802f13..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-broker.xml +++ /dev/null @@ -1,154 +0,0 @@ -<?xml version="1.0"?> -<!-- - censed 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. - */ ---> - -<configuration supports_final="true" xmlns:xi="http://www.w3.org/2001/XInclude";> - <property> - <name>listeners</name> - <value>PLAINTEXT://localhost:6667</value> - <property-type>DONT_ADD_ON_UPGRADE</property-type> - <description>host and port where kafka broker will be accepting connections. localhost will be substituted with hostname.</description> - </property> - <property> - <name>controlled.shutdown.enable</name> - <value>true</value> - <description>Enable controlled shutdown of the broker. If enabled, the broker will move all leaders on it to some other brokers before shutting itself down. This reduces the unavailability window during shutdown.</description> - </property> - <property> - <name>auto.leader.rebalance.enable</name> - <value>true</value> - <description>Enables auto leader balancing. A background thread checks and triggers leader balance if required at regular intervals</description> - </property> - <property> - <name>num.recovery.threads.per.data.dir</name> - <value>1</value> - <description>The number of threads per data directory to be used for log recovery at startup and flushing at shutdown</description> - </property> - <property> - <name>min.insync.replicas</name> - <value>1</value> - <description>define the minimum number of replicas in ISR needed to satisfy a produce request with required.acks=-1 (or all)</description> - </property> - <property> - <name>leader.imbalance.per.broker.percentage</name> - <value>10</value> - <description>The ratio of leader imbalance allowed per broker. The controller would trigger a leader balance if it goes above this value per broker. The value is specified in percentage.</description> - </property> - <property> - <name>leader.imbalance.check.interval.seconds</name> - <value>300</value> - <description>The frequency with which the partition rebalance check is triggered by the controller</description> - </property> - <property> - <name>offset.metadata.max.bytes</name> - <value>4096</value> - <description>The maximum size for a metadata entry associated with an offset commit</description> - </property> - <property> - <name>offsets.load.buffer.size</name> - <value>5242880</value> - <description>Batch size for reading from the offsets segments when loading offsets into the cache.</description> - </property> - <property> - <name>offsets.topic.replication.factor</name> - <value>3</value> - <description>The replication factor for the offsets topic (set higher to ensure availability). - To ensure that the effective replication factor of the offsets topic is the configured value, - the number of alive brokers has to be at least the replication factor at the time of the - first request for the offsets topic. If not, either the offsets topic creation will fail or it will get a replication factor of min(alive brokers, configured replication factor).</description> - </property> - <property> - <name>offsets.topic.num.partitions</name> - <value>50</value> - <description>The number of partitions for the offset commit topic (should not change after deployment)</description> - </property> - <property> - <name>offsets.topic.segment.bytes</name> - <value>104857600</value> - <description>The offsets topic segment bytes should be kept relatively small in order to facilitate faster log compaction and cache loads</description> - </property> - <property> - <name>offsets.topic.compression.codec</name> - <value>0</value> - <description>Compression codec for the offsets topic - compression may be used to achieve \"atomic\" commits. Default is NoCompression. For Gzip add value 1 , SnappyCompression add value 2, LZ4CompressionCodec 3. - </description> - </property> - <property> - <name>offsets.retention.minutes</name> - <value>86400000</value> - <description>Log retention window in minutes for offsets topic</description> - </property> - <property> - <name>offsets.retention.check.interval.ms</name> - <value>600000</value> - <description>Frequency at which to check for stale offsets</description> - </property> - <property> - <name>offsets.commit.timeout.ms</name> - <value>5000</value> - <description>Offset commit will be delayed until all replicas for the offsets topic receive the commit or this timeout is reached. This is similar to the producer request timeout.</description> - </property> - <property> - <name>offsets.commit.required.acks</name> - <value>-1</value> - <description>The required acks before the commit can be accepted. In general, the default (-1) should not be overridden</description> - </property> - <property> - <name>delete.topic.enable</name> - <value>false</value> - <description>Enables delete topic. Delete topic through the admin tool will have no effect if this config is turned off</description> - </property> - <property> - <name>compression.type</name> - <description>Specify the final compression type for a given topic. This configuration accepts the standard compression codecs ('gzip', 'snappy', lz4). It additionally accepts 'uncompressed' which is equivalent to no compression; and 'producer' which means retain the original compression codec set by the producer.</description> - <value>producer</value> - </property> - <property> - <name>port</name> - <value>6667</value> - <description>Deprecated config in favor of listeners config.</description> - <deleted>true</deleted> - </property> - <property> - <name>external.kafka.metrics.exclude.prefix</name> - <value>kafka.network.RequestMetrics,kafka.server.DelayedOperationPurgatory,kafka.server.BrokerTopicMetrics.BytesRejectedPerSec</value> - <description> - Exclude metrics starting with these prefixes from being collected. - </description> - </property> - <property> - <name>external.kafka.metrics.include.prefix</name> - <value>kafka.network.RequestMetrics.ResponseQueueTimeMs.request.OffsetCommit.98percentile,kafka.network.RequestMetrics.ResponseQueueTimeMs.request.Offsets.95percentile,kafka.network.RequestMetrics.ResponseSendTimeMs.request.Fetch.95percentile,kafka.network.RequestMetrics.RequestsPerSec.request</value> - <description> - These metrics would be included even if the exclude prefix omits them. - </description> - </property> - <property> - <name>authorizer.class.name</name> - <description> - Kafka authorizer class - </description> - <depends-on> - <property> - <type>ranger-kafka-plugin-properties</type> - <name>ranger-kafka-plugin-enabled</name> - </property> - </depends-on> - </property> -</configuration> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-env.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-env.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-env.xml deleted file mode 100644 index c17793f..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/kafka-env.xml +++ /dev/null @@ -1,28 +0,0 @@ -<?xml version="1.0"?> -<?xml-stylesheet type="text/xsl" href="configuration.xsl"?> -<!-- -/** - * 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. - */ ---> - -<configuration supports_adding_forbidden="true"> - <property> - <name>is_supported_kafka_ranger</name> - <value>true</value> - </property> -</configuration> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-audit.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-audit.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-audit.xml deleted file mode 100644 index 331daba..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-audit.xml +++ /dev/null @@ -1,178 +0,0 @@ -<?xml version="1.0"?> -<!-- -/** - * 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. - */ ---> -<configuration> - - <property> - <name>xasecure.audit.is.enabled</name> - <value>true</value> - <description>Is Audit enabled?</description> - </property> - - <property> - <name>xasecure.audit.destination.db</name> - <value>false</value> - <display-name>Audit to DB</display-name> - <description>Is Audit to DB enabled?</description> - <value-attributes> - <type>boolean</type> - </value-attributes> - <depends-on> - <property> - <type>ranger-env</type> - <name>xasecure.audit.destination.db</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.db.jdbc.url</name> - <value>{{audit_jdbc_url}}</value> - <description>Audit DB JDBC URL</description> - </property> - - <property> - <name>xasecure.audit.destination.db.user</name> - <value>{{xa_audit_db_user}}</value> - <description>Audit DB JDBC User</description> - </property> - - <property> - <name>xasecure.audit.destination.db.password</name> - <value>crypted</value> - <property-type>PASSWORD</property-type> - <description>Audit DB JDBC Password</description> - <value-attributes> - <type>password</type> - </value-attributes> - </property> - - <property> - <name>xasecure.audit.destination.db.jdbc.driver</name> - <value>{{jdbc_driver}}</value> - <description>Audit DB JDBC Driver</description> - </property> - - <property> - <name>xasecure.audit.credential.provider.file</name> - <value>jceks://file{{credential_file}}</value> - <description>Credential file store</description> - </property> - - <property> - <name>xasecure.audit.destination.db.batch.filespool.dir</name> - <value>/var/log/kafka/audit/db/spool</value> - <description>/var/log/kafka/audit/db/spool</description> - </property> - - <property> - <name>xasecure.audit.destination.hdfs</name> - <value>true</value> - <display-name>Audit to HDFS</display-name> - <description>Is Audit to HDFS enabled?</description> - <value-attributes> - <type>boolean</type> - </value-attributes> - <depends-on> - <property> - <type>ranger-env</type> - <name>xasecure.audit.destination.hdfs</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.hdfs.dir</name> - <value>hdfs://NAMENODE_HOSTNAME:8020/ranger/audit</value> - <description>HDFS folder to write audit to, make sure the service user has requried permissions</description> - <depends-on> - <property> - <type>ranger-env</type> - <name>xasecure.audit.destination.hdfs.dir</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.hdfs.batch.filespool.dir</name> - <value>/var/log/kafka/audit/hdfs/spool</value> - <description>/var/log/kafka/audit/hdfs/spool</description> - </property> - - <property> - <name>xasecure.audit.destination.solr</name> - <value>false</value> - <display-name>Audit to SOLR</display-name> - <description>Is Solr audit enabled?</description> - <value-attributes> - <type>boolean</type> - </value-attributes> - <depends-on> - <property> - <type>ranger-env</type> - <name>xasecure.audit.destination.solr</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.solr.urls</name> - <value></value> - <description>Solr URL</description> - <value-attributes> - <empty-value-valid>true</empty-value-valid> - </value-attributes> - <depends-on> - <property> - <type>ranger-admin-site</type> - <name>ranger.audit.solr.urls</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.solr.zookeepers</name> - <value>NONE</value> - <description>Solr Zookeeper string</description> - <depends-on> - <property> - <type>ranger-admin-site</type> - <name>ranger.audit.solr.zookeepers</name> - </property> - </depends-on> - </property> - - <property> - <name>xasecure.audit.destination.solr.batch.filespool.dir</name> - <value>/var/log/kafka/audit/solr/spool</value> - <description>/var/log/kafka/audit/solr/spool</description> - </property> - - <property> - <name>xasecure.audit.provider.summary.enabled</name> - <value>true</value> - <display-name>Audit provider summary enabled</display-name> - <description>Enable Summary audit?</description> - <value-attributes> - <type>boolean</type> - </value-attributes> - </property> - -</configuration> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-plugin-properties.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-plugin-properties.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-plugin-properties.xml deleted file mode 100644 index 18429a1..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-plugin-properties.xml +++ /dev/null @@ -1,90 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- -/** - * 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. - */ ---> -<configuration supports_final="true"> - - <property> - <name>policy_user</name> - <value>ambari-qa</value> - <display-name>Policy user for KAFKA</display-name> - <description>This user must be system user and also present at Ranger admin portal</description> - </property> - - <property> - <name>hadoop.rpc.protection</name> - <value></value> - <description>Used for repository creation on ranger admin</description> - <value-attributes> - <empty-value-valid>true</empty-value-valid> - </value-attributes> - </property> - - <property> - <name>common.name.for.certificate</name> - <value></value> - <description>Common name for certificate, this value should match what is specified in repo within ranger admin</description> - <value-attributes> - <empty-value-valid>true</empty-value-valid> - </value-attributes> - </property> - - <property> - <name>zookeeper.connect</name> - <value>localhost:2181</value> - <property-type>DONT_ADD_ON_UPGRADE</property-type> - <description>Used for repository creation on ranger admin</description> - </property> - - <property> - <name>ranger-kafka-plugin-enabled</name> - <value>No</value> - <display-name>Enable Ranger for KAFKA</display-name> - <description>Enable ranger kafka plugin</description> - <depends-on> - <property> - <type>ranger-env</type> - <name>ranger-kafka-plugin-enabled</name> - </property> - </depends-on> - <value-attributes> - <type>boolean</type> - <overridable>false</overridable> - </value-attributes> - </property> - - <property> - <name>REPOSITORY_CONFIG_USERNAME</name> - <value>kafka</value> - <display-name>Ranger repository config user</display-name> - <description>Used for repository creation on ranger admin</description> - </property> - - <property> - <name>REPOSITORY_CONFIG_PASSWORD</name> - <value>kafka</value> - <property-type>PASSWORD</property-type> - <display-name>Ranger repository config password</display-name> - <description>Used for repository creation on ranger admin</description> - <value-attributes> - <type>password</type> - </value-attributes> - </property> - -</configuration> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-policymgr-ssl.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-policymgr-ssl.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-policymgr-ssl.xml index 9ca4b43..3d14e1f 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-policymgr-ssl.xml +++ b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-policymgr-ssl.xml @@ -27,41 +27,9 @@ </property> <property> - <name>xasecure.policymgr.clientssl.keystore.password</name> - <value>myKeyFilePassword</value> - <property-type>PASSWORD</property-type> - <description>password for keystore</description> - <value-attributes> - <type>password</type> - </value-attributes> - </property> - - <property> <name>xasecure.policymgr.clientssl.truststore</name> <value>/usr/hdp/current/kafka-broker/config/ranger-plugin-truststore.jks</value> <description>java truststore file</description> </property> - <property> - <name>xasecure.policymgr.clientssl.truststore.password</name> - <value>changeit</value> - <property-type>PASSWORD</property-type> - <description>java truststore password</description> - <value-attributes> - <type>password</type> - </value-attributes> - </property> - - <property> - <name>xasecure.policymgr.clientssl.keystore.credential.file</name> - <value>jceks://file/{{credential_file}}</value> - <description>java keystore credential file</description> - </property> - - <property> - <name>xasecure.policymgr.clientssl.truststore.credential.file</name> - <value>jceks://file/{{credential_file}}</value> - <description>java truststore credential file</description> - </property> - </configuration> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-security.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-security.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-security.xml deleted file mode 100644 index 9dd858b..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/configuration/ranger-kafka-security.xml +++ /dev/null @@ -1,59 +0,0 @@ -<?xml version="1.0"?> -<!-- -/** - * 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. - */ ---> -<configuration> - - <property> - <name>ranger.plugin.kafka.service.name</name> - <value>{{repo_name}}</value> - <description>Name of the Ranger service containing policies for this Kafka instance</description> - </property> - - <property> - <name>ranger.plugin.kafka.policy.source.impl</name> - <value>org.apache.ranger.admin.client.RangerAdminRESTClient</value> - <description>Class to retrieve policies from the source</description> - </property> - - <property> - <name>ranger.plugin.kafka.policy.rest.url</name> - <value>{{policymgr_mgr_url}}</value> - <description>URL to Ranger Admin</description> - </property> - - <property> - <name>ranger.plugin.kafka.policy.rest.ssl.config.file</name> - <value>/etc/kafka/conf/ranger-policymgr-ssl.xml</value> - <description>Path to the file containing SSL details to contact Ranger Admin</description> - </property> - - <property> - <name>ranger.plugin.kafka.policy.pollIntervalMs</name> - <value>30000</value> - <description>How often to poll for changes in policies?</description> - </property> - - <property> - <name>ranger.plugin.kafka.policy.cache.dir</name> - <value>/etc/ranger/{{repo_name}}/policycache</value> - <description>Directory where Ranger policies are cached after successful retrieval from the source</description> - </property> - -</configuration> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/kerberos.json ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/kerberos.json b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/kerberos.json deleted file mode 100644 index eaa3d9d..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/kerberos.json +++ /dev/null @@ -1,49 +0,0 @@ -{ - "services": [ - { - "name": "KAFKA", - "identities": [ - { - "name": "/smokeuser" - } - ], - "configurations": [ - { - "kafka-broker": { - "authorizer.class.name": "kafka.security.auth.SimpleAclAuthorizer", - "principal.to.local.class":"kafka.security.auth.KerberosPrincipalToLocal", - "super.users": "user:${kafka-env/kafka_user}", - "security.inter.broker.protocol": "PLAINTEXTSASL" - } - } - ], - "components": [ - { - "name": "KAFKA_BROKER", - "identities": [ - { - "name": "kafka_broker", - "principal": { - "value": "${kafka-env/kafka_user}/_HOST@${realm}", - "type": "service", - "configuration": "kafka-env/kafka_principal_name" - }, - "keytab": { - "file": "${keytab_dir}/kafka.service.keytab", - "owner": { - "name": "${kafka-env/kafka_user}", - "access": "r" - }, - "group": { - "name": "${cluster-env/user_group}", - "access": "" - }, - "configuration": "kafka-env/kafka_keytab" - } - } - ] - } - ] - } - ] -} http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metainfo.xml ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metainfo.xml b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metainfo.xml index a40b08d..3ecf570 100644 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metainfo.xml +++ b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metainfo.xml @@ -21,9 +21,7 @@ <service> <name>KAFKA</name> <version>0.9.0.2.3</version> - <configuration-dependencies> - <config-type>kafka-broker</config-type> - </configuration-dependencies> + <extends>common-services/KAFKA/0.9.0</extends> </service> </services> </metainfo> http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metrics.json ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metrics.json b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metrics.json deleted file mode 100644 index e99f4eb..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/metrics.json +++ /dev/null @@ -1,239 +0,0 @@ -{ - "KAFKA_BROKER": { - "Component": [ - { - "type": "ganglia", - "metrics": { - "default": { - "metrics/jvm/uptime": { - "metric": "jvm.uptime", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/heap_usage": { - "metric": "jvm.heap_usage", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/non_heap_usage": { - "metric": "jvm.non_heap_usage", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/thread-states/runnable": { - "metric": "jvm.thread-states.runnable", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/thread-states/blocked": { - "metric": "jvm.thread-states.blocked", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/thread-states/timed_waiting": { - "metric": "jvm.thread-states.timed_waiting", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/thread-states/terminated": { - "metric": "jvm.thread-states.terminated", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/thread_count": { - "metric": "jvm.thread_count", - "pointInTime": true, - "temporal": true - }, - "metrics/jvm/daemon_thread_count": { - "metric": "jvm.daemon_thread_count", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/1MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.1MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/5MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.5MinuteRate", - "pointInTime": false, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/15MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.15MinuteRate", - "pointInTime": false, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/meanRate": { - "metric": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.meanRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/count": { - "metric": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.count", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/1MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.1MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/5MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.5MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/15MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.15MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/meanRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.meanRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/count": { - "metric": "kafka.server.BrokerTopicMetrics.BytesInPerSec.count", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/1MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/5MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.5MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/15MinuteRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.15MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/meanRate": { - "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.meanRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/count": { - "metric": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.count", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/KafkaController/ActiveControllerCount": { - "metric": "kafka.controller.KafkaController.ActiveControllerCount", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/meanRate": { - "metric": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.meanRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/1MinuteRate": { - "metric": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.1MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/5MinuteRate": { - "metric": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.5MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/15MinuteRate": { - "metric": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.15MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/count": { - "metric": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.count", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/UncleanLeaderElectionsPerSec/1MinuteRate": { - "metric": "kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.1MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/UncleanLeaderElectionsPerSec/5MinuteRate": { - "metric": "kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.5MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/UncleanLeaderElectionsPerSec/15MinuteRate": { - "metric": "kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.15MinuteRate", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/controller/ControllerStats/OfflinePartitionsCount": { - "metric": "kafka.controller.ControllerStats.OfflinePartitionsCount", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ReplicaManager/PartitionCount": { - "metric": "kafka.server.ReplicaManager.PartitionCount", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ReplicaManager/LeaderCount": { - "metric": "kafka.server.ReplicaManager.LeaderCount", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ReplicaManager/UnderReplicatedPartitions": { - "metric": "kafka.server.ReplicaManager.UnderReplicatedPartitions", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ReplicaManager/ISRShrinksPerSec": { - "metric": "kafka.server.ReplicaManager.ISRShrinksPerSec", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ReplicaManager/ISRExpandsPerSec": { - "metric": "kafka.server.ReplicaManager.ISRExpandsPerSec", - "pointInTime": true, - "temporal": true - }, - - "metrics/kafka/server/ReplicaFetcherManager/Replica-MaxLag": { - "metric": "kafka.server.ReplicaFetcherManager.MaxLag.clientId.Replica", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/ProducerRequestPurgatory/PurgatorySize": { - "metric": "kafka.server.ProducerRequestPurgatory.PurgatorySize", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/server/FetchRequestPurgatory/PurgatorySize": { - "metric": "kafka.server.FetchRequestPurgatory.PurgatorySize", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/cluster/Partition/$1-UnderReplicated": { - "metric": "kafka.cluster.Partition.(\\w+)-UnderReplicated", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/consumer/ConsumerFetcherManager/$1-MaxLag": { - "metric": "kafka.consumer.ConsumerFetcherManager.(\\w+)-MaxLag", - "pointInTime": true, - "temporal": true - }, - "metrics/kafka/consumer/ConsumerFetcherManager/$1-MinFetch": { - "metric": "kafka.consumer.ConsumerFetcherManager.(\\w+)-MinFetch", - "pointInTime": true, - "temporal": true - } - } - } - } - ] - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/widgets.json ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/widgets.json b/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/widgets.json deleted file mode 100644 index 7237236..0000000 --- a/ambari-server/src/main/resources/stacks/HDP/2.3/services/KAFKA/widgets.json +++ /dev/null @@ -1,182 +0,0 @@ -{ - "layouts": [ - { - "layout_name": "default_kafka_dashboard", - "display_name": "Standard Kafka Dashboard", - "section_name": "KAFKA_SUMMARY", - "widgetLayoutInfo": [ - { - "widget_name": "Broker Topics", - "description": "Broker Topics", - "widget_type": "GRAPH", - "is_visible": true, - "metrics": [ - { - "name": "kafka.server.BrokerTopicMetrics.BytesInPerSec.1MinuteRate", - "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesInPerSec/1MinuteRate", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - }, - { - "name": "kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate", - "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsBytesOutPerSec/1MinuteRate", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - }, - { - "name": "kafka.server.BrokerTopicMetrics.MessagesInPerSec.1MinuteRate", - "metric_path": "metrics/kafka/server/BrokerTopicMetrics/AllTopicsMessagesInPerSec/1MinuteRate", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - } - ], - "values": [ - { - "name": "Bytes In", - "value": "${kafka.server.BrokerTopicMetrics.BytesInPerSec.1MinuteRate}" - }, - { - "name": "Bytes Out", - "value": "${kafka.server.BrokerTopicMetrics.BytesOutPerSec.1MinuteRate}" - }, - { - "name": "Messages In", - "value": "${kafka.server.BrokerTopicMetrics.MessagesInPerSec.1MinuteRate}" - } - ], - "properties": { - "graph_type": "LINE", - "time_range": "1" - } - }, - { - "widget_name": "Active Controller Count", - "description": "Active Controller Count", - "widget_type": "GRAPH", - "is_visible": true, - "metrics": [ - { - "name": "kafka.controller.KafkaController.ActiveControllerCount", - "metric_path": "metrics/kafka/controller/KafkaController/ActiveControllerCount", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - } - ], - "values": [ - { - "name": "Active Controller Count", - "value": "${kafka.controller.KafkaController.ActiveControllerCount}" - } - ], - "properties": { - "graph_type": "LINE", - "time_range": "1" - } - }, - { - "widget_name": "Controller Status", - "description": "Controller Status", - "widget_type": "GRAPH", - "is_visible": true, - "metrics": [ - { - "name": "kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.1MinuteRate", - "metric_path": "metrics/kafka/controller/ControllerStats/LeaderElectionRateAndTimeMs/1MinuteRate", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - }, - { - "name": "kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.1MinuteRate", - "metric_path": "metrics/kafka/controller/ControllerStats/UncleanLeaderElectionsPerSec/1MinuteRate", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - } - ], - "values": [ - { - "name": "Leader Election Rate And Time", - "value": "${kafka.controller.ControllerStats.LeaderElectionRateAndTimeMs.1MinuteRate}" - }, - { - "name": "Unclean Leader Election", - "value": "${kafka.controller.ControllerStats.UncleanLeaderElectionsPerSec.1MinuteRate}" - } - ], - "properties": { - "graph_type": "LINE", - "time_range": "1" - } - }, - { - "widget_name": "Replica MaxLag", - "description": "Replica MaxLag", - "widget_type": "GRAPH", - "is_visible": true, - "metrics": [ - { - "name": "kafka.server.ReplicaFetcherManager.MaxLag.clientId.Replica", - "metric_path": "metrics/kafka/server/ReplicaFetcherManager/Replica-MaxLag", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - } - ], - "values": [ - { - "name": "Replica MaxLag", - "value": "${kafka.server.ReplicaFetcherManager.MaxLag.clientId.Replica}" - } - ], - "properties": { - "graph_type": "LINE", - "time_range": "1" - } - }, - { - "widget_name": "Replica Manager", - "description": "Replica Manager", - "widget_type": "GRAPH", - "is_visible": true, - "metrics": [ - { - "name": "kafka.server.ReplicaManager.PartitionCount", - "metric_path": "metrics/kafka/server/ReplicaManager/PartitionCount", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - }, - { - "name": "kafka.server.ReplicaManager.UnderReplicatedPartitions", - "metric_path": "metrics/kafka/server/ReplicaManager/UnderReplicatedPartitions", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - }, - { - "name": "kafka.server.ReplicaManager.LeaderCount", - "metric_path": "metrics/kafka/server/ReplicaManager/LeaderCount", - "service_name": "KAFKA", - "component_name": "KAFKA_BROKER" - } - ], - "values": [ - { - "name": "Partitions count", - "value": "${kafka.server.ReplicaManager.PartitionCount}" - }, - { - "name": "Under Replicated Partitions", - "value": "${kafka.server.ReplicaManager.UnderReplicatedPartitions}" - }, - { - "name": "Leader Count", - "value": "${kafka.server.ReplicaManager.LeaderCount}" - } - ], - "properties": { - "graph_type": "LINE", - "time_range": "1" - } - } - - ] - } - ] -} http://git-wip-us.apache.org/repos/asf/ambari/blob/10e4d1cd/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py b/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py index 117a4bc..d6afa50 100644 --- a/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py +++ b/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py @@ -25,7 +25,7 @@ from only_for_platform import not_for_platform, PLATFORM_WINDOWS @not_for_platform(PLATFORM_WINDOWS) class TestKafkaBroker(RMFTestCase): - COMMON_SERVICES_PACKAGE_DIR = "KAFKA/0.8.1.2.2/package" + COMMON_SERVICES_PACKAGE_DIR = "KAFKA/0.8.1/package" STACK_VERSION = "2.2" def test_configure_default(self):
