{"id":6632,"date":"2021-08-31T17:33:18","date_gmt":"2021-08-31T09:33:18","guid":{"rendered":"https:\/\/nj.transwarp.cn:8180\/?p=6632"},"modified":"2021-08-31T17:35:31","modified_gmt":"2021-08-31T09:35:31","slug":"kafka-stream-%e5%ae%89%e5%85%a8%e9%85%8d%e7%bd%ae%e9%97%ae%e9%a2%98%e6%a3%80%e6%9f%a5","status":"publish","type":"post","link":"https:\/\/kbwp.transwarp.cn\/?p=6632","title":{"rendered":"kafka stream \u5b89\u5168\u914d\u7f6e\u95ee\u9898\u68c0\u67e5"},"content":{"rendered":"<h3>\u6982\u8981\u63cf\u8ff0<\/h3>\n<hr \/>\n<p>kafka\u5e38\u89c1\u95ee\u9898<\/p>\n<h3>\u8be6\u7ec6\u8bf4\u660e<\/h3>\n<hr \/>\n<p>1 \u4e0a\u6e38kafka\u6d41\u7684\u6d41\u4efb\u52a1\u8fd0\u884c\u6b63\u5e38\uff0c\u4f46\u4e0b\u6e38\u6ca1\u6570\u636e\u67e5\u770bslipstream server\u65e5\u5fd7<br \/>\n<img decoding=\"async\" src=\"\/wp-content\/uploads\/2021\/08\/image-1630402072789.png\" alt=\"file\" \/><\/p>\n<p>\u6392\u67e5\u6b65\u9aa4<\/p>\n<p>\u201cCould not login: the client is being asked for a password&#8230;\u201d \u8fd9\u4e2a\u62a5\u9519\u4fe1\u606f\u5e76\u4e0d\u662f\u5f88\u5177\u4f53\uff0c\u53ef\u80fd\u4f1a\u6709\u5f88\u591a\u539f\u56e0\u5bfc\u81f4\u8fd9\u4e2a\u62a5\u9519\u3002<\/p>\n<p>step1: \u68c0\u67e5kafka\u5b89\u5168\u6d41\u7684tblproperties\u914d\u7f6e\u5185\u5bb9<\/p>\n<p>\u68c0\u67e5\u5b89\u5168\u76f8\u5173\u5c5e\u6027\u662f\u5426\u90fd\u5df2\u6dfb\u52a0\uff0c\uff08\u8fd9\u4e00\u6b65\u53ef\u4ee5\u53c2\u7167\u624b\u518c\u8fdb\u884c\uff0c\u7740\u91cd\u770bproperties\u540d\u79f0\u662f\u5426\u90fd\u5b58\u5728\uff09<\/p>\n<pre><code class=\"language-sql\">-- TDH-client\u767b\u9646beeline\nshow databases;\nuse <YOUR_DATA_BASE>;\nshow create table <YOUR_DATA_BASE>.<YOUR_KAFKA_STREAM_NAME>;<\/code><\/pre>\n<p>2.\u7740\u91cd\u68c0\u67e5&quot;sasl.jaas.config&quot;\u8fd9\u4e00\u9879\u5185\u5bb9\u3002\u6574\u7406\u7ecf\u5e38\u9047\u5230\u7684\u9519\u8bef\u793a\u8303\u5982\u4e0b<\/p>\n<pre><code class=\"language-sql\"># required\uff0cuserKeyTab=true\uff0ckeyTab princpal\u4e4b\u95f4\u90fd\u9700\u8981\u6709\u7a7a\u683c&\u6216\u8005\u6362\u884c\uff0c\u8fde\u5728\u4e00\u8d77\u4f1a\u62a5\u9519\u3002\n## \u274c\u5404\u4e2a\u5c5e\u6027\u4e4b\u95f4\u7f3a\u5c11\u7a7a\u683c\uff0crequired\u540e\u7f3a\u5c11\u7a7a\u683c\n\"com.sun.security.auth.module.Krb5LoginModule requireduseKeyTab=true storeKey=true keyTab=\\\"\/etc\/slipstream1\/conf\/kafka.keytab\\\" principal=\\\"kafka@TDH\\\"\"\n## \u274cprincipal\u5185\u5bb9\u4e0d\u6b63\u786e\uff08\u4e0b\u65b9\u793a\u4f8b\u4e2dprincipal\u4e2d\u5305\u542b\u4e00\u4e2a\u7a7a\u683c\uff09\n\"com.sun.security.auth.module.Krb5LoginModule requireduseKeyTab=true storeKey=true keyTab=\\\"\/etc\/slipstream1\/conf\/kafka.keytab\\\" principal=\\\" kafka@TDH\\\"\"\n## \u274c kafka.keytab\u8def\u5f84\u95ee\u9898\n### 1. \u6587\u4ef6\u662f\u5426\u5b58\u5728\u76f8\u5e94\u7684\u76ee\u5f55\n### 2. \u662f\u5426\u6bcf\u4e2aexecutor\u6240\u5728\u7684\u8282\u70b9\u90fd\u5b58\u5728\n### 3. \u67e5\u770b\u4e0b\u6bcf\u4e2a\u8282\u70b9\u7684kafka.keytab\u6587\u4ef6\u5927\u5c0f\u662f\u5426\u4e00\u81f4\u3002<\/code><\/pre>\n<p>step2: \u68c0\u67e5keytab<\/p>\n<pre><code class=\"language-sql\"># \u5efa\u8bae\u6bcf\u4e2aexecutor\u8282\u70b9\u90fd\u770b\u4e0b\nklist -ket \/etc\/slipstream1\/conf\/kafka.keytab\n# \u53ef\u80fd\u8f93\u51fa\u7684\u7ed3\u679c\u5982\u4e0b\nKeytab name: FILE:\/etc\/slipstream1\/conf\/kafka.keytab\n\nKVNO Timestamp           Principal\n---- ------------------- ------------------------------------------------------\n   0 2020-12-02T01:30:05 kafka@TDH (aes128-cts-hmac-sha1-96) \n   0 2020-12-02T01:30:05 kafka@TDH (aes256-cts-hmac-sha1-96) \n   0 2020-12-02T01:30:05 kafka@TDH (des3-cbc-sha1) \n   0 2020-12-02T01:30:05 kafka@TDH (des-cbc-md5) \n   0 2020-12-02T01:30:05 kafka@TDH (arcfour-hmac) \n\n# \u26a0\ufe0f \u8fd9\u91cc\u7684Principal\u5e94\u5f53\u4e0ekafka stream tblProperties\u4e2d\u7684 principal\u5185\u5bb9\u76f8\u540c\n# \u26a0\ufe0f \u6bcf\u4e2aexecutor\u8282\u70b9\u7684keytab\u7ed3\u679c\u5e94\u8be5\u662f\u4e00\u6837\u7684\uff01\uff01\uff01\n# \u26a0\ufe0f \u6bcf\u4e2aexecutor\u8282\u70b9\u4e0a\u7684keytab\u6587\u4ef6\u8def\u5f84\u5e94\u8be5\u76f8\u540c\uff01\uff01\uff01\n# \u26a0\ufe0f \u6bcf\u4e2aexecutor\u8282\u70b9\u4e0a\u7684keytab\u6587\u4ef6\uff0c\u90fd\u5e94\u8be5\u53ef\u4ee5\u5728pod\u4e2d\u8bbf\u95ee\u5230\uff01\uff01\uff01<\/code><\/pre>\n<p>Tips1 slipsteram server\u65e5\u5fd7<\/p>\n<pre><code class=\"language-sql\"># \u901a\u8fc7manager\u7b49\u9875\u9762\u627e\u5230slipstream-server\u6240\u5728\u8282\u70b9\n# \u767b\u5165\u8282\u70b9\n# \u8fdb\u5165\u65e5\u5fd7\u76ee\u5f55\ncd \/var\/log\/slipstream1\/\nls -all\n# server \u65e5\u5fd7\u4e00\u822c\u7684\u540d\u79f0\u4e3ahive-server*.log<\/code><\/pre>\n<p>Tip2 \u8fdb\u5165slipstream executor pod<\/p>\n<pre><code class=\"language-sql\">#\u67e5\u770b slipstream pod\nkubectl get pods |grep slipstream\n## \u53ef\u80fd\u7684\u8f93\u51fa\ninceptor-executor1-slipstream1-7c845fcb48-7g5mw         1\/1     Running   0          34h\ninceptor-executor1-slipstream1-7c845fcb48-pjpdc         1\/1     Running   0          34h\ninceptor-executor1-slipstream1-7c845fcb48-qknct         1\/1     Running   0          34h\ninceptor-server-slipstream1-79fffdfd56-bmq8c            1\/1     Running   0          34h\n\n## \u8fdb\u5165\u67d0\u4e00\u4e2aexecutor pod\nkubectl exec -it inceptor-executor1-slipstream1-7c845fcb48-7g5mw \/bin\/bash\n## \u9000\u51fapod\u56de\u5230\u5bbf\u4e3b\u673a\nexit #\u56de\u8f66\n<\/code><\/pre>\n<p>Tip3\u670d\u52a1\u5668\u95f4\u6587\u4ef6\u62f7\u8d1d<\/p>\n<pre><code class=\"language-sql\"># \u4f8b\u5982\u628astream1\u8282\u70b9\u4e0a\u7684keytab\u590d\u5236\u5230stream2\u8282\u70b9\u4e0a\n## \u5982\u679c\u5f53\u524d\u5728stream1\nscp \/etc\/slipstream1\/conf\/kafka.keytab root@stream2:\/etc\/slipstream1\/conf #\u56de\u8f66 -> \u8f93\u5165\u5bc6\u7801 ->\u56de\u8f66\n## \u5982\u679c\u5f53\u524d\u767b\u9646\u5728stream2\u4e0a\nscp root@stream1:\/etc\/slipstream\/conf\/kafka.keytab \/etc\/slipstream1\/conf #\u56de\u8f66 -> \u8f93\u5165\u5bc6\u7801 ->\u56de\u8f66<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>\u6982\u8981\u63cf\u8ff0 kafka\u5e38\u89c1\u95ee\u9898 \u8be6\u7ec6\u8bf4\u660e 1 \u4e0a\u6e38kafka\u6d41\u7684\u6d41\u4efb\u52a1\u8fd0\u884c\u6b63\u5e38\uff0c\u4f46\u4e0b\u6e38\u6ca1\u6570\u636e\u67e5\u770bslipstre ..<\/p>\n<div class=\"clear-fix\"><\/div>\n<p><a href=\"https:\/\/kbwp.transwarp.cn\/?p=6632\" title=\"read more...\">Read more<\/a><\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-6632","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"acf":[],"_links":{"self":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/6632","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=6632"}],"version-history":[{"count":2,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/6632\/revisions"}],"predecessor-version":[{"id":6825,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=\/wp\/v2\/posts\/6632\/revisions\/6825"}],"wp:attachment":[{"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=6632"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=6632"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kbwp.transwarp.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=6632"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}