tencent cloud

Tencent Cloud Observability Platform

Release Notes and Announcements
Release Notes
Product Introduction
Overview
Strengths
Basic Features
Basic Concepts
Use Cases
Use Limits
Purchase Guide
Tencent Cloud Product Monitoring
Application Performance Management
Mobile App Performance Monitoring
Real User Monitoring
Cloud Automated Testing
Prometheus Monitoring
Grafana
EventBridge
PTS
Quick Start
Monitoring Overview
Instance Group
Tencent Cloud Product Monitoring
Application Performance Management
Real User Monitoring
Cloud Automated Testing
Performance Testing Service
Prometheus Getting Started
Grafana
Dashboard Creation
EventBridge
Alarm Service
Cloud Product Monitoring
Tencent Cloud Service Metrics
Operation Guide
CVM Agents
Cloud Product Monitoring Integration with Grafana
Troubleshooting
Practical Tutorial
Application Performance Management
Product Introduction
Access Guide
Operation Guide
Practical Tutorial
Parameter Information
FAQs
Mobile App Performance Monitoring
Overview
Operation Guide
Access Guide
Practical Tutorial
Tencent Cloud Real User Monitoring
Product Introduction
Operation Guide
Connection Guide
FAQs
Cloud Automated Testing
Product Introduction
Operation Guide
FAQs
Performance Testing Service
Overview
Operation Guide
Practice Tutorial
JavaScript API List
FAQs
Prometheus Monitoring
Product Introduction
Access Guide
Operation Guide
Practical Tutorial
Terraform
FAQs
Grafana
Product Introduction
Operation Guide
Guide on Grafana Common Features
FAQs
Dashboard
Overview
Operation Guide
Alarm Management
Console Operation Guide
Troubleshooting
FAQs
EventBridge
Product Introduction
Operation Guide
Practical Tutorial
FAQs
Report Management
FAQs
General
Alarm Service
Concepts
Monitoring Charts
CVM Agents
Dynamic Alarm Threshold
CM Connection to Grafana
Documentation Guide
Related Agreements
Application Performance Management Service Level Agreement
APM Privacy Policy
APM Data Processing And Security Agreement
RUM Service Level Agreement
Mobile Performance Monitoring Service Level Agreement
Cloud Automated Testing Service Level Agreement
Prometheus Service Level Agreement
TCMG Service Level Agreements
PTS Service Level Agreement
PTS Use Limits
Cloud Monitor Service Level Agreement
API Documentation
History
Introduction
API Category
Making API Requests
Monitoring Data Query APIs
Alarm APIs
Legacy Alert APIs
Notification Template APIs
TMP APIs
Grafana Service APIs
Event Center APIs
TencentCloud Managed Service for Prometheus APIs
Monitoring APIs
Data Types
Error Codes
Glossary
ドキュメントTencent Cloud Observability PlatformEventBridgeOperation GuideEvent SourceConnectorConfiguring CKafka Connector

Configuring CKafka Connector

PDF
フォーカスモード
フォントサイズ
最終更新日: 2024-11-01 20:41:50

Overview

You can configure a CKafka connector to consume content in CKafka message queues. A CKafka connector is implemented in the pull pattern. It automatically pulls CKafka content and routes events to relevant services through event rules. This document describes how to create a CKafka connector and the structure of events generated by the CKafka connector.

Prerequisites

Directions

1. Log in to the EventBridge console and select Event Bus on the left sidebar.
2. In the Event Bus list, select the event bus for which you want to configure a CKafka connector.
3. On the Event Bus Details page, click Add in the connector configuration section.


4. Enter the relevant information as prompted as shown below:

Here, select CMQ (Kafka) for Connector type and enter other configuration items as prompted.
Note:
Currently, only delivery for Tencent Cloud CKafka instances is supported. Please confirm that no username and password have been configured for your CKafka instances; otherwise, the connector may fail to get messages.
5. Click OK.
6. Select Event Rule on the left sidebar.
7. In the drop-down lists at the top of the Event Rule page, select the same connector information as that set during connector creation and click Create Event Rule as shown below:


8. Enter the relevant information as prompted as shown below:

Here, select Message Queue CKafka for Tencent Cloud service and configure the delivery target.
9. Click OK.

Structure of events generated by the CKafka connector

 {       
        "specversion":"1.0",       
        "id":"13a3f42d-7258-4ada-da6d-023a333b4662",    
        "type":"connector:kafka",   
        "source":"ckafka.cloud.tencent",   
        "subject": "qcs::ckafka:ap-guangzhou:uin/1250000000:ckafkaId/uin/1250000000/ckafka-123456",     
        "time":"1615430559146",   
        "region":"ap-guangzhou",       
        "datacontenttype":"application/json;charset=utf-8",   
        "data":{             
             "topic":"test-topic",         
             "Partition":1,         
             "offset":37,         
             "msgKey":"test",         
             "msgBody":"Hello from Ckafka again!"      
           }
}
The parameters are described as follows:
Parameter
Description
topic
CKafka delivery topic.
Partition
Event source partition. One topic can contain one or more partitions. CKafka uses partition as an allocation unit.
offset
Consumer group, which specifies the consumption start point.
msgKey
CKafka message key.
msgBody
CKafka message body.
前の記事へ: Configuring APIGW Connector次の記事へ: Configuring a DTS Connector

ヘルプとサポート

この記事はお役に立ちましたか？

フィードバック