ApsaraMQ for Kafka:Tablestore sink connector oluşturma

Ön koşullar

• ApsaraMQ for Kafka

  • Örnek için connector özelliğini etkinleştirdiniz. Daha fazla bilgi için bkz. Connector'leri etkinleştirme.

  • Örnek için bir kaynak konu oluşturdunuz. Daha fazla bilgi için bkz. Adım 1: Konu oluşturma.

• Tablestore

  • Tablestore'u etkinleştirdiniz ve bir örnek oluşturdunuz. Daha fazla bilgi için bkz. Tablestore'u etkinleştirme ve örnek oluşturma.

Notlar

• Bir ApsaraMQ for Kafka örneğindeki bir kaynak konudan yalnızca aynı bölgedeki Tablestore'a veri aktarabilirsiniz. Connector sınırları hakkında bilgi için bkz. Kullanım sınırlamaları.

• Bir connector oluşturduğunuzda, ApsaraMQ for Kafka otomatik olarak hizmet bağlantılı bir rol oluşturur.

  • Hizmet bağlantılı bir rol yoksa, ApsaraMQ for Kafka otomatik olarak bir tane oluşturarak ApsaraMQ for Kafka hizmetinin Tablestore'a veri aktarmasını sağlar.

  • Hizmet bağlantılı bir rol zaten varsa, ApsaraMQ for Kafka yeni bir rol oluşturmaz.

  Hizmet bağlantılı roller hakkında daha fazla bilgi için bkz. Hizmet bağlantılı roller.

Yordam

Bu konu, bir ApsaraMQ for Kafka örneğindeki bir kaynak konudan Tablestore'a veri aktarmak için Tablestore sink connector'ünün nasıl kullanılacağını açıklar.

1. İsteğe bağlı: Tablestore sink connector için gereken konuları ve group öğelerini oluşturun.

   Konuları ve group öğelerini özelleştirmeniz gerekmiyorsa bu adımı atlayıp sonraki adımda Otomatik seçeneğini belirleyebilirsiniz.

   Önemli

   Tablestore sink connector tarafından gereken bazı konular Yerel depolama altyapısını kullanmalıdır. 0.10.2 ana sürümüne sahip ApsaraMQ for Kafka örnekleri için Yerel depolama altyapısı kullanan konuları manuel olarak oluşturamazsınız. Bu konular yalnızca otomatik olarak oluşturulabilir.

   1. Tablestore sink connector için konuları oluşturma

   2. Tablestore sink connector için group oluşturma

2. Tablestore sink connector oluşturma ve dağıtma

3. Sonucu doğrulayın

   1. Test mesajı gönderme

   2. Tablodaki verileri görüntüleme

Tablestore sink connector için konuları oluşturma

ApsaraMQ for Kafka konsolunda, Tablestore sink connector için gereken beş konuyu manuel olarak oluşturun: bir görev ofseti konusu, bir görev yapılandırması konusu, bir görev durumu konusu, bir dead-letter queue konusu ve bir hata verisi konusu. Gerekli bölüm sayısı ve depolama altyapısı her konu için farklılık gösterir. Daha fazla bilgi için bkz. Kaynak hizmet parametrelerinin listesi.

1. ApsaraMQ for Kafka konsoluna giriş yapın.

2. Overview sayfasında, Resource Distribution bölümünde bir bölge seçin.

   Önemli

   Konuları, uygulamanızın bulunduğu bölgede (ECS örneğinin dağıtıldığı bölgede) oluşturmanız gerekir. Konular bölgeler arası kullanılamaz. Örneğin, bir konu China (Beijing) bölgesinde oluşturulursa mesaj üreticisi ve tüketicisi de China (Beijing) bölgesindeki bir ECS örneğinde çalışmalıdır.

3. Instances sayfasında hedef örneğin adını tıklayın.

4. Sol gezinme bölmesinde Topics seçeneğini tıklayın.

5. Topics sayfasında Create Topic seçeneğini tıklayın.

6. Create Topic panelinde konu özelliklerini ayarlayın ve ardından OK seçeneğini tıklayın.

   Parametre	Açıklama	Örnek
   Name	Konunun adı. Not Kafka'da xxx_xxx ve xxx.xxx gibi konu adları aynı kabul edilir. Yinelenen ada sahip bir konu oluşturmaya çalışırsanız hata raporlanır.	demo
   Description	Konu hakkında kısa bir açıklama.	demo test
   Partitions	Konudaki bölüm sayısı.	12
   Storage Engine Not Şu anda depolama altyapısı türünü yalnızca Serverless Professional Edition olmayan örnekler için seçebilirsiniz. Diğer örneklerde bu parametre desteklenmez ve varsayılan olarak Cloud Storage olarak ayarlanır.	Konu mesajları için depolama altyapısı. ApsaraMQ for Kafka aşağıdaki iki depolama altyapısını destekler. Cloud Storage: Alt katmanda Alibaba Cloud disklerini kullanır. Bu depolama altyapısı düşük gecikme süresi, yüksek performans, yüksek dayanıklılık ve yüksek güvenilirlik sunar. Dağıtılmış üç çoğaltma mekanizması kullanır. Örneğin Instance Edition değeri Standard (High Write) ise depolama altyapısı yalnızca Cloud Storage olabilir. Local Storage: Yerel Kafka eş zamanlı çoğaltma (ISR) çoğaltma algoritmasını ve dağıtılmış üç çoğaltma mekanizmasını kullanır.	Cloud Storage
   Message Type	Konu mesajlarının türü. Normal Message: Varsayılan olarak aynı anahtara sahip mesajlar aynı bölüme dağıtılır ve bir bölüm içindeki mesajlar gönderildikleri sırayla depolanır. Kümedeki bir makine çökerse mesajların sırası bozulabilir. Storage Engine değerini Cloud Storage olarak ayarladığınızda varsayılan olarak Normal Message seçilir. Partitionally Ordered Message: Varsayılan olarak aynı anahtara sahip mesajlar aynı bölüme dağıtılır ve bir bölüm içindeki mesajlar gönderildikleri sırayla depolanır. Kümedeki bir makine çökerse mesajların sırası bölüm içinde yine de korunur. Ancak bazı bölümlere mesaj gönderme işlemi başarısız olabilir. Bölümler kurtarıldıktan sonra normal işlemler devam eder. Storage Engine değerini Local Storage olarak ayarladığınızda varsayılan olarak Partitionally Ordered Message seçilir.	Normal Message
   Log Cleanup Policy	Konu günlükleri için temizleme ilkesi. Storage Engine değerini Local Storage olarak ayarladığınızda Log Cleanup Policy yapılandırmanız gerekir. Depolama altyapısını Yerel Depolama olarak yalnızca Professional Edition örnekler için ayarlayabilirsiniz. Standard Edition örnekler desteklenmez. ApsaraMQ for Kafka aşağıdaki iki temizleme ilkesini destekler. Delete: Varsayılan mesaj temizleme ilkesidir. Disk kapasitesi yeterliyse mesajlar maksimum saklama süresi boyunca tutulur. Disk kapasitesi yetersizse (genellikle disk kullanımı %85'i aştığında) hizmetin kullanılabilirliğini sağlamak için eski mesajlar erken silinir. Compact: Kafka Log Compaction temizleme ilkesini kullanır. Log Compaction ilkesi, aynı anahtara sahip mesajlar için en son değerin her zaman saklanmasını sağlar. Bu durum, genellikle bir sistem arızasından sonra durumu kurtarma veya sistem yeniden başlatıldıktan sonra önbelleği yeniden yükleme gibi senaryolar için geçerlidir. Örneğin, Kafka Connect veya Confluent Schema Registry kullanırken sistem durumunu veya yapılandırma bilgilerini depolamak için bir Kafka Compact Topic kullanmanız gerekir. Önemli Compact konular genellikle yalnızca Kafka Connect veya Confluent Schema Registry gibi belirli ekosistem bileşenlerinde kullanılır. Diğer mesaj gönderme ve alma senaryolarındaki konular için bu özelliği ayarlamayın. Daha fazla bilgi için bkz. ApsaraMQ for Kafka Demo Library.	Compact
   Tag	Konunun etiketleri.	demo

   Konu oluşturulduktan sonra Topics sayfasındaki listede görüntülenir.

Tablestore sink connector için group oluşturma

ApsaraMQ for Kafka konsolunda Tablestore sink connector veri senkronizasyon görevi için manuel olarak bir group oluşturabilirsiniz. Bu group öğesinin adı connect-Görev Adı biçiminde olmalıdır. Daha fazla bilgi için bkz. Kaynak hizmet parametreleri.

1. ApsaraMQ for Kafka konsoluna giriş yapın.

2. Overview sayfasında, Resource Distribution bölümünde bir bölge seçin.

3. Instances sayfasında hedef örneğin adını tıklayın.

4. Sol gezinme bölmesinde Groups seçeneğini tıklayın.

5. Groups sayfasında Create Group seçeneğini tıklayın.

6. Create Group panelinde, Group ID metin kutusuna group için bir ad girin, Description metin kutusuna kısa bir açıklama yazın, group öğesine etiketler ekleyin ve ardından OK seçeneğini tıklayın.

   Group oluşturulduktan sonra Groups sayfasındaki listede görüntülenir.

Tablestore sink connector oluşturma ve dağıtma

Bir ApsaraMQ for Kafka örneğinden bir Tablestore tablosuna veri senkronize etmek için Tablestore sink connector oluşturun ve dağıtın.

1. ApsaraMQ for Kafka konsoluna giriş yapın.

2. Overview sayfasında, Resource Distribution bölümünde bir bölge seçin.

3. Sol gezinme bölmesinde Connectors seçeneğini tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden connector'ün ait olduğu örneği seçin ve Create Connector seçeneğini tıklayın.

5. Create Connector sihirbazında aşağıdaki adımları tamamlayın.

   1. Configure Basic Information sekmesinde aşağıdaki parametreleri yapılandırın ve ardından Next seçeneğini tıklayın.

      Parametre	Açıklama	Örnek
      Name	Connector'ün adı. Ad aşağıdaki gereksinimleri karşılamalıdır: Ad en fazla 48 karakter uzunluğunda olabilir ve yalnızca rakamlar, küçük harfler ve tire (-) içerebilir. Tire (-) ile başlayamaz. Ad, bir ApsaraMQ for Kafka örneği içinde benzersiz olmalıdır. Connector'ün veri senkronizasyon görevi, connect-task-name adlı bir consumer group kullanır. Bu consumer group öğesini manuel olarak oluşturmazsanız sistem bunu otomatik olarak oluşturur.	kafka-ts-sink
      Instance	Varsayılan olarak örnek adı ve örnek kimliği görüntülenir.	demo alikafka_post-cn-st21p8vj****

   2. Configure Source Service sekmesinde, Data Source değerini ApsaraMQ for Kafka olarak ayarlayın, aşağıdaki parametreleri yapılandırın ve ardından Next seçeneğini tıklayın.

      Not

      Gerekli konuyu ve group öğesini zaten oluşturduysanız kaynak oluşturma için Manual seçeneğini belirleyip bunların bilgilerini girin. Aksi takdirde Auto seçeneğini belirleyin.

      Tablo 1. Kaynak hizmet parametreleri

      Parametre	Açıklama	Örnek
      Data Source Topic	Veri senkronizasyonu için kaynak konu.	ts-test-input
      Consumer Thread Concurrency	Veri kaynağı konusu için eşzamanlı tüketici iş parçacığı sayısı. Varsayılan değer 6'dır. Geçerli değerler: 1 2 3 6 12	6
      Consumer Offset	Mesaj tüketimi için başlangıç konumu. Geçerli değerler: Earliest Offset: Mesajları en eski ofsetten tüketir. Latest Offset: Mesajları en son ofsetten tüketir.	Earliest Offset
      VPC ID	Veri senkronizasyon görevinin çalıştığı sanal özel cloud'un (VPC) kimliği. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Bu parametre varsayılan olarak ApsaraMQ for Kafka örneğinin VPC'sidir ve yapılandırma gerektirmez.	vpc-bp1xpdnd3l***
      vSwitch ID	Veri senkronizasyon görevinin çalıştığı vSwitch'in kimliği. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. vSwitch, ApsaraMQ for Kafka örneğiyle aynı VPC'de olmalıdır. Bu parametre, ApsaraMQ for Kafka örneği dağıtılırken belirtilen vSwitch'e varsayılan olarak atanır.	vsw-bp1d2jgg81***
      Failure Handling Policy	Bir konu bölümündeki mesaj gönderme hatalarını işleme ilkesi. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Geçerli değerler: Continue Subscription: Hatanın oluştuğu konu bölümüne aboneliği sürdürür ve hata günlüklerini yazdırır. Stop Subscription: Hatanın oluştuğu konu bölümüne aboneliği durdurur ve hata günlüklerini yazdırır. Not Günlükleri görüntüleme hakkında daha fazla bilgi için bkz. Connector'leri yönetme. Hata kodlarına göre çözüm bulma hakkında daha fazla bilgi için bkz. Hata kodları.	Continue Subscription
      Resource Creation Method	Gerekli konuları ve group öğelerini oluşturma yöntemi. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Auto Manual	Auto
      Connector Consumer Group	Veri senkronizasyon görevi tarafından kullanılan consumer group. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. group öğesinin adı connect-task-name biçiminde olmalıdır.	connect-cluster-kafka-ots-sink
      Task Offset Topic	Consumer ofsetlerini depolayan konu. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Konu: Konu adı connect-offset ile başlamalıdır. Bölümler: Konu için bölüm sayısı 1'den büyük olmalıdır. Depolama altyapısı: Konu için depolama altyapısı Yerel Depolama olmalıdır. cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.	connect-offset-kafka-ots-sink
      Task Configuration Topic	Görev yapılandırmalarını depolayan konu. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Konu: Konu adı connect-config ile başlamalıdır. Bölümler: Konu için bölüm sayısı 1 olmalıdır. Depolama altyapısı: Konu için depolama altyapısı Yerel Depolama olmalıdır. cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.	connect-config-kafka-ots-sink
      Task Status Topic	Görev durumunu depolayan konu. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Konu: Konu adı connect-status ile başlamalıdır. Bölümler: Önerilen bölüm sayısı 6'dır. Depolama altyapısı: Konu için depolama altyapısı Yerel Depolama olmalıdır. cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.	connect-status-kafka-ots-sink
      Dead-letter Queue Topic	Kafka Connect çerçevesinden gelen hata verilerini depolamak için kullanılan konu. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Konu kaynaklarını tasarruf etmek için dead-letter queue ve Error Data Topic için aynı konuyu kullanabilirsiniz. Konu: Konu adı connect-error ile başlamalıdır. Bölümler: Önerilen bölüm sayısı 6'dır. Depolama altyapısı: Konu için depolama altyapısı Yerel Depolama veya Bulut Depolama olabilir.	connect-error-kafka-ots-sink
      Error Data Topic	Sink'ten gelen hata verilerini depolamak için kullanılan konu. Bu parametre, Configure Runtime Environment seçeneğini tıkladıktan sonra görüntülenir. Konu kaynaklarını tasarruf etmek için Dead-letter Queue Topic ve hata verisi konusu için aynı konuyu kullanabilirsiniz. Konu: Konu adı connect-error ile başlamalıdır. Bölümler: Önerilen bölüm sayısı 6'dır. Depolama altyapısı: Konu için depolama altyapısı Yerel Depolama veya Bulut Depolama olabilir.	connect-error-kafka-ots-sink

   3. Configure Destination Service sekmesinde, Destination Service değerini Tablestore olarak ayarlayın, aşağıdaki parametreleri yapılandırın ve ardından Create seçeneğini tıklayın.

      Parametre	Açıklama	Örnek
      Instance Name	Tablestore örneğinin adı.	k00eny67****
      Automatically Create Destination Table	Tablestore'da otomatik olarak tablo oluşturulup oluşturulmayacağını belirtir. Yes: Yapılandırılan tablo adına göre senkronize edilen verileri depolamak için Tablestore'da otomatik olarak bir tablo oluşturulur. No: Senkronize edilen verileri depolamak için mevcut bir tablo kullanılır.	Yes
      Destination Table Name	Senkronize edilen verileri depolayan tablonun adı. Automatically Create Destination Table değerini No olarak ayarlarsanız tablo adı, Tablestore örneğindeki mevcut bir tablonun adıyla aynı olmalıdır.	kafka_table
      Tablestore	Senkronize edilen verileri depolayan tablonun türü. Wide Column Model TimeSeries Model	Wide Column Model
      Message Key Format	Mesaj anahtarının giriş formatı. Geçerli değerler String ve JSON'dir. Varsayılan değer JSON'dir. Bu parametre yalnızca Tablestore değeri Wide Column Model olarak ayarlandığında görüntülenir. String: Mesaj anahtarı doğrudan dize olarak ayrıştırılır. JSON: Mesaj anahtarı JSON formatında olmalıdır.	String
      Message Value Format	Mesaj değerinin giriş formatı. Geçerli değerler String ve JSON'dir. Varsayılan değer JSON'dir. Bu parametre yalnızca Tablestore değeri Wide Column Model olarak ayarlandığında görüntülenir. String: Mesaj değeri doğrudan dize olarak ayrıştırılır. JSON: Mesaj değeri JSON formatında olmalıdır.	String
      JSON Message Field Conversion	JSON mesajındaki alanları işleme yöntemi. Bu parametre, Message Key Format veya Message Value Format değerini JSON olarak ayarlarsanız görüntülenir. Geçerli değerler: Write All as String: Tüm alanları Tablestore'da String türüne dönüştürür. Automatically Identify Field Types: JSON mesaj gövdesindeki String ve Boolean alanlarını Tablestore'daki karşılık gelen String ve Boolean türlerine dönüştürür. JSON mesaj gövdesindeki Integer ve Float veri türleri Tablestore'da Double türüne dönüştürülür.	Write All as String
      Primary Key Mode	Birincil anahtar modunu belirtir. Tablo birincil anahtarlarını koordinatlar (konu, bölüm ve ofset), anahtar ve değer dahil olmak üzere ApsaraMQ for Kafka mesaj kayıtlarının farklı bölümlerinden çıkarabilirsiniz. Bu parametre yalnızca Tablestore değeri Wide Column Model olarak ayarlandığında görüntülenir. Varsayılan değer kafka'dır. kafka: <connect_topic>_<connect_partition> ve <connect_offset> değerlerini veri tablosunun birincil anahtarları olarak kullanır. record_key: Kayıt anahtarındaki alanları veri tablosunun birincil anahtarları olarak kullanır. record_value: Kayıt değerindeki alanları veri tablosunun birincil anahtarları olarak kullanır.	kafka
      Primary Key Column Names	Veri tablosunun birincil anahtar sütun adları ve bunlara karşılık gelen veri türleri. String ve Integer veri türleri desteklenir. Bu, yapılandırılan sütun adlarıyla eşleşen kayıt anahtarı veya değerindeki alanların veri tablosu için birincil anahtar olarak kullanılacağı anlamına gelir. Bu parametre, Message Key Format değerini JSON ve Primary Key Mode değerini record_key olarak ayarlarsanız veya Message Value Format değerini JSON ve Primary Key Mode değerini record_value olarak ayarlarsanız görüntülenir. Sütun adı eklemek için Create seçeneğini tıklayın. En fazla dört sütun adı yapılandırabilirsiniz.	None
      Write Mode	Yazma modunu belirtir. Geçerli değerler put ve update'tir. Varsayılan değer put'tur. Bu parametre yalnızca Tablestore değeri Wide Column Model olarak ayarlandığında görüntülenir. put: Mevcut verilerin üzerine yazar. update: Mevcut verileri günceller.	put
      Delete Mode	Bir ApsaraMQ for Kafka mesaj kaydı null değerler içeriyorsa satırları veya nitelik sütunlarını silmeyi seçebilirsiniz. Bu parametre, Primary Key Mode değeri record_key olarak ayarlandığında görüntülenir. Geçerli değerler: none: Varsayılan değer. Silmeye izin verilmez. row: Satır silmeye izin verir. column: Nitelik sütunu silmeye izin verir. row_and_column: Satır ve nitelik sütunu silmeye izin verir. Silme davranışı yazma moduna bağlıdır: Write Mode değeri put ise, değer null alanlar içerdiğinde bile herhangi bir silme modu Tablestore veri tablosuna üzerine yazma işlemiyle sonuçlanır. Write Mode değeri update ve silme modu none veya row ise tüm değer alanları null olan kayıtlar kirli veri olarak kabul edilir. Yalnızca bazı değer alanları null ise connector null alanları yoksayar ve null olmayan alanları Tablestore veri tablosuna yazar. Silme modu column veya row_and_column ise connector null alanlar için satırları ve nitelik sütunlarını siler ve ardından verileri Tablestore veri tablosuna yazar.	None
      Metric Name Field	Bu alan, Tablestore TimeSeries Model'indeki ölçüm adı alanına (_m_name) eşlenir. Ölçüm adı, sıcaklık veya hız gibi zaman serisi verileri için fiziksel miktarın veya izleme ölçümünün adını belirtir. Bu alan boş bırakılamaz. Bu parametre, Tablestore için TimeSeries Model'i seçtiğinizde görüntülenir.	measurement
      Data Source Field	Bu alanı Tablestore TimeSeries Model'indeki veri kaynağı alanına (_data_source) eşler. Bu alan, makine adı veya cihaz kimliği gibi zaman serisi verilerinin kaynağı için bir tanımlayıcı görevi görür ve boş bırakılabilir. Bu parametre, Tablestore için TimeSeries modeli seçildiğinde görüntülenir.	source
      Tag Field	Bir veya daha fazla alanı Tablestore TimeSeries Model'i için etiket alanları (_tags) olarak kullanın. Her etiket, dizelerin bir anahtar-değer çiftidir. Anahtar, yapılandırılan alanın adıdır ve değer, alanın içeriğidir. Etiketler, zaman serisi meta verilerinin bir parçasıdır. Bir zaman serisi, ölçüm adı, veri kaynağı ve etiketlerin kombinasyonu ile benzersiz şekilde tanımlanır. Etiketler boş bırakılabilir. Bu parametre, zaman serisi modeli olarak Tablestore seçildiğinde görüntülenir.	tag1, tag2
      Timestamp Field	Bu alanı Tablestore TimeSeries Model'indeki zaman damgası alanına (_time) eşler. Bu alan, zaman serisi verilerinin bu satırı için zaman noktasını temsil eder (örneğin, fiziksel bir niceliğin oluşturulduğu zaman). Veriler Tablestore'a yazıldığında zaman damgası alanı yazma ve depolama için mikrosaniyeye dönüştürülür. Bu parametre, Tablestore için TimeSeries Model'i seçtiğinizde görüntülenir.	time
      Timestamp Unit	Bu parametreyi gerçek zaman damgası alanına göre yapılandırın. Bu parametre yalnızca Tablestore değeri TimeSeries Model olarak ayarlandığında görüntülenir. Geçerli değerler: SECONDS MILLISECONDS MICROSECONDS NANOSECONDS	MILLISECONDS
      Whether to Map All Non-primary Key Fields	Birincil anahtar olmayan tüm alanların veri alanları olarak eşlenip eşlenmeyeceğini belirtir. Birincil anahtar olmayan alanlar, zaten ölçüm adı, veri kaynağı, etiket veya zaman damgası olarak eşlenmemiş alanlardır. Bu parametre yalnızca Tablestore değeri TimeSeries Model olarak ayarlandığında görüntülenir. Geçerli değerler: Yes: Alanlar otomatik olarak eşlenir ve veri türleri belirlenir. Sayısal türlerin tümü Double türüne dönüştürülür. No: Eşlenecek alanları ve türleri belirtmeniz gerekir.	Yes
      Configure Mapping for All Non-primary Key Fields	Zaman serisi tablosunun birincil anahtar olmayan alan adlarına karşılık gelen alan türleri. Double, Integer, String, Binary ve Boolean veri türleri desteklenir. Bu parametre, Whether to Map All Non-primary Key Fields değerini No olarak ayarlarsanız görüntülenir.	String

      Connector oluşturulduktan sonra Connectors sayfasında görüntüleyebilirsiniz.

6. Connector oluşturulduktan sonra Connectors sayfasında bulup Actions sütunundaki Deploy seçeneğini tıklayın.

7. OK seçeneğini tıklayın.

Test mesajı gönderme

Tablestore sink connector'ü dağıttıktan sonra verilerin Tablestore'a senkronize edildiğini doğrulamak için ApsaraMQ for Kafka içindeki kaynak konuya bir mesaj gönderebilirsiniz.

1. Connectors sayfasında hedef connector'ü bulun ve Actions sütunundaki Test seçeneğini tıklayın.

2. Send Message panelinde bir test mesajı gönderin.

   • Sending Method değerini Console olarak ayarlayın.

     1. Message Key metin kutusuna mesajın anahtarını girin. Örneğin, demo.

     2. Message Content metin kutusuna test mesajının içeriğini girin. Örneğin, {"key": "test"}.

     3. Mesajın belirli bir bölüme gönderilip gönderilmeyeceğini belirtmek için Send to Specified Partition değerini ayarlayın.

        • Yes seçeneğini tıklayın ve Partition ID metin kutusuna bölüm kimliğini girin. Örneğin, 0. Bölüm kimliğini sorgulamak için bkz. Bölüm durumunu görüntüleme.

        • Bir bölüm belirtmemek için No seçeneğini tıklayın.

   • Sending Method değerini Docker olarak ayarlayın. Mesajı göndermek için Run the Docker container to produce a sample message bölümündeki Docker komutunu çalıştırın.

   • Sending Method değerini SDK olarak ayarlayın. Mesaj göndermek için gerekli dil veya çerçeve için bir SDK ve bir bağlantı türü seçin.

Tablo verilerini görüntüleme