Juniper NETWORKS Streaming API මෘදුකාංග පරිශීලක මාර්ගෝපදේශය

හැඳින්වීම:
මෙම මාර්ගෝපදේශය නිෂ්පාදනයේ ප්‍රවාහ API භාවිතයෙන් Paragon Active Assurance වෙතින් දත්ත උපුටා ගන්නා ආකාරය පිළිබඳ උපදෙස් සපයයි. ප්‍රවාහ සේවාලාභියා සහ API Paragon Active Assurance ස්ථාපනය තුළ ඇතුළත් කර ඇත, නමුත් API භාවිතා කිරීමට පෙර යම් වින්‍යාසයක් අවශ්‍ය වේ. වින්‍යාස කිරීමේ ක්‍රියාවලිය "ප්‍රවාහ API වින්‍යාස කිරීම" කොටසේ ආවරණය කර ඇත.

Streaming API වින්‍යාස කිරීම:
පහත පියවර මඟින් ප්‍රවාහ API වින්‍යාස කිරීමේ ක්‍රියාවලිය ගෙනහැර දක්වයි:

ඉවරයිview
Kafka යනු විවිධ ප්‍රභවයන්ගෙන් දත්ත තත්‍ය කාලීන ග්‍රහණය කර ගැනීම සහ ගබඩා කිරීම සඳහා නිර්මාණය කර ඇති සිදුවීම් ප්‍රවාහ වේදිකාවකි. එය බෙදා හරින ලද, පරිමාණය කළ හැකි, දෝෂ-ඉවසන සහ ආරක්ෂිත ආකාරයකින් සිදුවීම් ප්‍රවාහ කළමනාකරණය කිරීමට ඉඩ සලසයි. මෙම මාර්ගෝපදේශය Paragon Active Assurance Control Center හි Streaming API විශේෂාංගය භාවිතා කිරීමට Kafka වින්‍යාස කිරීම කෙරෙහි අවධානය යොමු කරයි.

පාරිභාෂිතය
Streaming API බාහිර සේවාදායකයන්ට Kafka වෙතින් ප්‍රමිතික තොරතුරු ලබා ගැනීමට ඉඩ දෙයි. පරීක්ෂණයක් හෝ අධීක්ෂණ කාර්යයක් අතරතුර පරීක්ෂණ නියෝජිතයන් විසින් එකතු කරන ලද ප්‍රමිතික ප්‍රවාහ සේවාව වෙත යවනු ලැබේ. සැකසීමෙන් පසුව, Stream සේවාව අමතර පාර-දත්ත සමග Kafka මත මෙම මිතික ප්‍රකාශ කරයි.

කෆ්කා මාතෘකා
ප්‍රවාහ API ප්‍රමිතික සහ පාර-දත්ත සංවිධානය කිරීමට සහ ගබඩා කිරීමට Kafka මාතෘකා භාවිතා කරයි. කෆ්කා මාතෘකා නිශ්චිත අවශ්‍යතා අනුව නිර්මාණය කර කළමනාකරණය කළ හැක.

Streaming API සබල කරමින්
Streaming API සබල කිරීමට, මෙම පියවර අනුගමනය කරන්න:

sudo භාවිතයෙන් පාලන මධ්‍යස්ථාන සේවාදායකයේ පහත විධානයන් ක්‍රියාත්මක කරන්න:

KAFKA_METRICS_ENABLED = සත්‍ය sudo ncc සේවා කාලපරිමාණ ප්‍රමිතික sudo ncc සේවා සක්‍රීය කරයි timescaledb metrics sudo ncc සේවා නැවත ආරම්භ කිරීම

ප්‍රවාහ API පාලන මධ්‍යස්ථානයේ ක්‍රියා කරන බව තහවුරු කිරීම:
ඔබට නිවැරදි කෆ්කා මාතෘකා පිළිබඳ ප්‍රමිතික ලැබෙන බව තහවුරු කිරීමට:

පහත විධානයන් සමඟ kafkacat උපයෝගීතාව ස්ථාපනය කරන්න:
sudo apt-get update
sudo apt-get install kafkacat

ඔබගේ ගිණුමේ කෙටි නම සමඟ "myaccount" ප්‍රතිස්ථාපනය කරන්න
පාලන මධ්යස්ථානය URL:
අපනයනය METRICS_TOPIC=paa.public.accounts.myaccount.metrics
අපනයනය METADATA_TOPIC=paa.public.accounts.myaccount.metadata

පහත විධානය ක්‍රියාත්මක කරන්න view මිනුම්:
kafkacat -b ${KAFKA_FQDN}:9092 -t ${METRICS_TOPIC} -C -e
සටහන: ඉහත විධානය ප්‍රමිතික පෙන්වයි.
වෙත view පාරදත්ත, පහත විධානය ක්‍රියාත්මක කරන්න:
kafkacat -b ${KAFKA_FQDN}:9092 -t ${METADATA_TOPIC} -C -e

සටහන: ඉහත විධානය පාර-දත්ත පෙන්වනු ඇත, නමුත් එය නිතර යාවත්කාලීන නොවේ.

සේවාලාභියා හිටපුamples
හිටපු සේවාදායකයා සඳහාamples සහ වැඩිදුර තොරතුරු, පරිශීලක අත්පොතෙහි 14 පිටුව බලන්න.

නිතර අසන ප්‍රශ්න (නිතර අසන ප්‍රශ්න)

Q: Paragon Active Assurance යනු කුමක්ද?
A: Paragon Active Assurance යනු අධීක්ෂණ සහ පරීක්ෂණ හැකියාවන් සපයන නිෂ්පාදනයකි.

Q: Streaming API යනු කුමක්ද?
A: Streaming API යනු Paragon Active Assurance හි විශේෂාංගයක් වන අතර එය බාහිර සේවාලාභීන්ට Kafka වෙතින් ප්‍රමිතික තොරතුරු ලබා ගැනීමට ඉඩ සලසයි.
ප්‍ර: Streaming API සක්‍රීය කරන්නේ කෙසේද?
A: Streaming API සබල කිරීමට, පරිශීලක අත්පොතෙහි "Sreaming API සබල කිරීම" කොටසේ දක්වා ඇති පියවර අනුගමනය කරන්න.

ප්‍ර: Streaming API ක්‍රියා කරන බව මම සත්‍යාපනය කරන්නේ කෙසේද?
A: Streaming API හි ක්‍රියාකාරීත්වය සත්‍යාපනය කරන්නේ කෙසේද යන්න පිළිබඳ උපදෙස් සඳහා “Control Center තුළ Streaming API ක්‍රියා කරන බව සත්‍යාපනය කිරීම” කොටස බලන්න.

හැඳින්වීම

නිෂ්පාදනයේ ප්‍රවාහ API හරහා Paragon Active Assurance වෙතින් දත්ත උපුටා ගන්නා ආකාරය මෙම මාර්ගෝපදේශය විස්තර කරයි.
පැරගන් ඇක්ටිව් ඇෂුවරන්ස් ස්ථාපනය තුළ API මෙන්ම ප්‍රවාහ සේවාලාභියා ඇතුළත් වේ. කෙසේ වෙතත්, ඔබට API භාවිතා කිරීමට පෙර වින්‍යාසය ටිකක් අවශ්‍ය වේ. මෙය 1 පිටුවේ පරිච්ඡේදයේ "Sreaming API වින්‍යාස කිරීම" තුළ ආවරණය කර ඇත.

ඉවරයිview
මෙම පරිච්ඡේදය Kafka හරහා Metrics පණිවිඩ වලට දායක වීමට ඉඩ සලසන Streaming API වින්‍යාස කරන්නේ කෙසේද යන්න විස්තර කරයි.
pr
පහත අපි හරහා යන්නෙමු:

Streaming API සබල කරන්නේ කෙසේද

බාහිර ගනුදෙනුකරුවන්ට සවන් දීමට Kafka වින්‍යාස කරන්නේ කෙසේද
ACL භාවිතා කිරීමට Kafka වින්‍යාස කරන්නේ කෙසේද සහ එම සේවාදායකයින් සඳහා SSL සංකේතනය සකසන්නේ කෙසේද

කෆ්කා යනු කුමක්ද?
Kafka යනු සිදුවීම් ප්‍රවාහයේ ස්වරූපයෙන් විවිධ සිදුවීම් මූලාශ්‍රවලින් (සංවේදක, දත්ත සමුදායන්, ජංගම උපාංග) යවන ලද දත්ත තත්‍ය කාලීන ග්‍රහණය කර ගැනීමට ඉඩ සලසන සිදුවීම්-ප්‍රවාහ වේදිකාවකි.
Kafka සමඟින් බෙදා හරින ලද, ඉහළ පරිමාණය කළ හැකි, ප්‍රත්‍යාස්ථ, දෝෂ-ඉවසන සහ ආරක්ෂිත ආකාරයෙන් සිදුවීම් ප්‍රවාහය අවසානයේ සිට අවසානය දක්වා කළමනාකරණය කළ හැකිය.

සටහන: Kafka විවිධ ආකාරවලින් වින්‍යාස කළ හැකි අතර පරිමාණය සහ අතිරික්ත පද්ධති සඳහා නිර්මාණය කර ඇත. මෙම ලේඛනය අවධානය යොමු කරන්නේ Paragon Active Assurance Control Center හි ඇති Streaming API විශේෂාංගය භාවිතා කිරීම සඳහා එය වින්‍යාස කරන්නේ කෙසේද යන්න පිළිබඳව පමණි. වඩාත් උසස් සැකසුම් සඳහා අපි නිල Kafka ලේඛන වෙත යොමු වන්න: kafka.apache.org/26/documentation.html.

පාරිභාෂිතය

කෆ්කා: සිදුවීම්-ප්‍රවාහ වේදිකාව.

කෆ්කා මාතෘකාව: සිදුවීම් එකතුව.
කෆ්කා ග්‍රාහකයා/පාරිභෝගික: කෆ්කා මාතෘකාවක් තුළ ගබඩා කර ඇති සිදුවීම් නැවත ලබා ගැනීම සඳහා වගකිව යුතු සංරචකය.
කෆ්කා තැරැව්කරු: කෆ්කා පොකුරක ගබඩා ස්තර සේවාදායකය.
SSL/TLS: SSL යනු අන්තර්ජාලය හරහා ආරක්ෂිතව තොරතුරු යැවීම සඳහා සකස් කරන ලද ආරක්ෂිත ප්‍රොටෝකෝලයකි. TLS යනු 1999 දී හඳුන්වා දුන් SSL හි අනුප්‍රාප්තිකයයි.
SASL: පරිශීලක සත්‍යාපනය, දත්ත අඛණ්ඩතාව පරීක්ෂා කිරීම සහ සංකේතනය සඳහා යාන්ත්‍රණ සපයන රාමුව.
Streaming API ග්‍රාහකයා: Paragon Active Assurance හි නිර්වචනය කර ඇති සහ බාහිර ප්‍රවේශය සඳහා අදහස් කර ඇති මාතෘකා තුළ ගබඩා කර ඇති සිදුවීම් නැවත ලබා ගැනීම සඳහා වගකිව යුතු සංරචකය.
සහතික අධිකාරිය: පොදු යතුරු සහතික නිකුත් කරන සහ අවලංගු කරන විශ්වාසදායක ආයතනයකි.
සහතික අධිකාරිය මූල සහතිකය: සහතික අධිකාරියක් හඳුනා ගන්නා පොදු යතුරු සහතිකය.

Streaming API ක්‍රියා කරන ආකාරය
කලින් සඳහන් කළ පරිදි, Streaming API බාහිර සේවාදායකයින්ට Kafka වෙතින් ප්‍රමිතික පිළිබඳ තොරතුරු ලබා ගැනීමට ඉඩ දෙයි.

පරීක්ෂණයක් හෝ අධීක්ෂණ කාර්යයක් අතරතුර පරීක්ෂණ නියෝජිතයින් විසින් එකතු කරන ලද සියලුම ප්‍රමිතික ප්‍රවාහ සේවාව වෙත යවනු ලැබේ. සැකසුම් අදියරකින් පසුව, Stream සේවාව අමතර පාර-දත්ත සමග Kafka මත එම මිනුම් දණ්ඩ ප්‍රකාශයට පත් කරයි.

කෆ්කා මාතෘකා
Kafka සතුව සියලුම දත්ත ප්‍රකාශනය කරන මාතෘකා පිළිබඳ සංකල්පය ඇත. Paragon Active Assurance හි එවැනි Kafka මාතෘකා බොහොමයක් තිබේ; කෙසේ වෙතත්, මේවායේ උප කුලකයක් පමණක් බාහිර ප්‍රවේශය සඳහා අදහස් කෙරේ.
පාලන මධ්‍යස්ථානයේ ඇති සෑම Paragon Active Assurance ගිණුමකටම කැප වූ මාතෘකා දෙකක් ඇත. පහත, ACCOUNT යනු ගිණුමේ කෙටි නමයි:

paa.public.accounts.{ACCOUNT}.metrics
- ලබා දී ඇති ගිණුම සඳහා වන සියලුම ප්‍රමිතික පණිවිඩ මෙම මාතෘකාවට ප්‍රකාශනය කෙරේ
- දත්ත විශාල ප්‍රමාණයක්
- ඉහළ යාවත්කාලීන සංඛ්යාතය
paa.public.accounts.{ACCOUNT}.metadata
- ප්‍රමිතික දත්තවලට අදාළ පාරදත්ත අඩංගු වේ, උදාampප්‍රමිතික හා සම්බන්ධ පරීක්ෂණය, මොනිටරය හෝ පරීක්ෂණ නියෝජිතයා වේ
- කුඩා දත්ත ප්‍රමාණයක්
- අඩු යාවත්කාලීන සංඛ්යාතය

Streaming API සබල කරමින්

සටහන: මෙම උපදෙස් sudo භාවිතයෙන් පාලන මධ්‍යස්ථාන සේවාදායකයේ ක්‍රියාත්මක කළ යුතුය.

Streaming API පාලන මධ්‍යස්ථානයට යම් පොදු කාර්යක් එක් කරන බැවින්, එය පෙරනිමියෙන් සක්‍රීය නොවේ. API සක්‍රීය කිරීමට, අපි ප්‍රථමයෙන් ප්‍රධාන වින්‍යාසය තුළ කෆ්කා වෙත ප්‍රමිතික ප්‍රකාශනය සක්‍රීය කළ යුතුය. file:

/etc/netrounds/netrounds.conf

KAFKA_METRICS_ENABLED = ඇත්ත

අවවාදයයි: මෙම විශේෂාංගය සක්‍රීය කිරීම පාලන මධ්‍යස්ථාන ක්‍රියාකාරිත්වයට බලපෑ හැකිය. ඔබ ඔබේ අවස්ථාව ඒ අනුව මානය කර ඇති බවට වග බලා ගන්න.

ඊළඟට, මෙම මිතික නිවැරදි කෆ්කා මාතෘකා වෙත යොමු කිරීම සබල කිරීමට:

/etc/netrounds/metrics.yaml

streaming-api: ඇත්ත

Streaming API සේවා සබල කිරීමට සහ ආරම්භ කිරීමට, ධාවනය කරන්න:

sudo ncc සේවා කාලපරිමාණ බී මෙට්‍රික් සක්‍රීය කරයි
sudo ncc සේවා කාලපරිමාණ බී මෙට්‍රික්ස් ආරම්භ කරයි

අවසාන වශයෙන්, සේවාවන් නැවත ආරම්භ කරන්න:

sudo ncc සේවා නැවත ආරම්භ කරන්න

පාලන මධ්‍යස්ථානයේ Streaming API ක්‍රියා කරන බව තහවුරු කිරීම

සටහන: මෙම උපදෙස් පාලන මධ්‍යස්ථාන සේවාදායකයේ ක්‍රියාත්මක විය යුතුය.

ඔබට දැන් නිවැරදි කෆ්කා මාතෘකා පිළිබඳ ප්‍රමිතික ලැබෙන බව සත්‍යාපනය කළ හැක. එසේ කිරීමට, kafkacat උපයෝගීතාව ස්ථාපනය කරන්න:

sudo apt-get update

sudo apt-get install kafkacat

ඔබට පාලන මධ්‍යස්ථානයේ ධාවනය වන පරීක්ෂණයක් හෝ මොනිටරයක් තිබේ නම්, ඔබට මෙම මාතෘකා පිළිබඳ ප්‍රමිතික සහ පාර-දත්ත ලබා ගැනීමට kafkacat භාවිත කිරීමට හැකි විය යුතුය.
myaccount ඔබේ ගිණුමේ කෙටි නම සමඟ ප්‍රතිස්ථාපනය කරන්න (ඔබේ පාලන මධ්‍යස්ථානයේ ඔබ දකින්නේ මෙයයි URL):

අපනයනය METRICS_TOPIC=paa.public.accounts.myaccount.metrics

අපනයනය METADATA_TOPIC=paa.public.accounts.myaccount.metadata

මෙම විධානය ක්‍රියාත්මක කිරීමෙන් ඔබ දැන් ප්‍රමිතික දැකිය යුතුය:

kafkacat -b ${KAFKA_FQDN}:9092 -t ${METRICS_TOPIC} -C -e

වෙත view පාරදත්ත, පහත විධානය ක්‍රියාත්මක කරන්න (මෙය නිතර යාවත්කාලීන නොවන බව සලකන්න):

kafkacat -b ${KAFKA_FQDN}:9092 -t ${METADATA_TOPIC} -C -e

සටහන:
kafkacat"සේවාලාභියා හිටපුamp14 වන පිටුවේ

පාලන මධ්‍යස්ථානය තුලින් අපට ක්‍රියාකරන Streaming API එකක් ඇති බව මෙය සත්‍යාපනය කරයි. කෙසේ වෙතත්, බොහෝ විට ඔබ ඒ වෙනුවට බාහිර සේවාදායකයෙකුගෙන් දත්ත වෙත ප්රවේශ වීමට උනන්දු වනු ඇත. බාහිර ප්රවේශය සඳහා Kafka විවෘත කරන ආකාරය ඊළඟ කොටස විස්තර කරයි.

බාහිර සත්කාරක සඳහා Kafka විවෘත කිරීම

සටහන: මෙම උපදෙස් පාලන මධ්‍යස්ථාන සේවාදායකයේ ක්‍රියාත්මක විය යුතුය.

පෙරනිමියෙන් පාලන මධ්‍යස්ථානයේ ධාවනය වන Kafka අභ්‍යන්තර භාවිතය සඳහා localhost මත පමණක් සවන් දීමට වින්‍යාස කර ඇත. Kafka සැකසුම් වෙනස් කිරීමෙන් බාහිර සේවාදායකයින් සඳහා Kafka විවෘත කළ හැකිය.

කෆ්කා වෙත සම්බන්ධ කිරීම: අවවාදය

අවවාදය: ඔබ මෙම සංකල්ප තේරුම් ගෙන නොමැති නම් කෆ්කා සමඟ සම්බන්ධ ගැටළු වලට මුහුණ දීම පහසු බැවින් කරුණාකර මෙය හොඳින් කියවන්න.

මෙම ලේඛනයේ විස්තර කර ඇති පාලන මධ්‍යස්ථාන සැකසුම තුළ ඇත්තේ තනි කෆ්කා තැරැව්කරුවකු පමණි.
කෙසේ වෙතත්, කෆ්කා තැරැව්කරුවෙකු බොහෝ කෆ්කා තැරැව්කරුවන්ගෙන් සමන්විත විය හැකි කෆ්කා පොකුරක කොටසක් ලෙස ක්‍රියාත්මක වීමට අදහස් කරන බව සලකන්න.
Kafka තැරැව්කරුවකු වෙත සම්බන්ධ වන විට, Kafka සේවාලාභියා විසින් මූලික සම්බන්ධතාවයක් පිහිටුවනු ලැබේ. මෙම සම්බන්ධතාවය හරහා කෆ්කා තැරැව්කරු "ප්‍රචාරණය කරන ලද සවන්දෙන්නන්" ලැයිස්තුවක් ආපසු ලබා දෙනු ඇත, එය කෆ්කා තැරැව්කරුවන් එකක හෝ වැඩි ගණනක ලැයිස්තුවකි.
මෙම ලැයිස්තුව ලැබුණු විට, Kafka සේවාලාභියා විසන්ධි කර, පසුව මෙම ප්‍රචාරණය කරන ලද සවන්දෙන්නන්ගෙන් කෙනෙකුට නැවත සම්බන්ධ වනු ඇත. ප්‍රචාරණය කරන ලද සවන්දෙන්නන් සතුව Kafka සේවාලාභියාට ප්‍රවේශ විය හැකි සත්කාරක නාම හෝ IP ලිපින තිබිය යුතුය, නැතහොත් සේවාලාභියා සම්බන්ධ වීමට අසමත් වනු ඇත.
SSL සංකේතනය භාවිතා කරන්නේ නම්, විශේෂිත ධාරක නාමයකට බැඳී ඇති SSL සහතිකයක් ඇතුළත් වේ නම්, Kafka සේවාලාභියාට සම්බන්ධ වීමට නිවැරදි ලිපිනය ලැබීම වඩාත් වැදගත් වේ, එසේ නොවුවහොත් සම්බන්ධතාවය ප්‍රතික්ෂේප විය හැක.
කෆ්කා අසන්නන් ගැන වැඩි විස්තර මෙතැනින් කියවන්න: www.confluent.io/blog/kafka-listeners-explained

SSL/TLS සංකේතනය
විශ්වාසදායක සේවාලාභීන්ට පමණක් Kafka සහ Streaming API වෙත ප්‍රවේශ වීමට අවසර ඇති බව තහවුරු කර ගැනීමට, අපි පහත සඳහන් දෑ වින්‍යාස කළ යුතුය:

සත්යාපනය: සේවාදායකයා සහ කෆ්කා අතර SSL/TLS ආරක්ෂිත සම්බන්ධතාවයක් හරහා සේවාලාභීන් පරිශීලක නාමය සහ මුරපදය සැපයිය යුතුය.
අවසර දීම: සත්‍යාපිත සේවාලාභීන්ට ACL මගින් නියාමනය කරන ලද කාර්යයන් ඉටු කළ හැක.

මෙන්න ඕවර් එකක්view:

*) පරිශීලක නාමය/මුරපද සත්‍යාපනය SSL-සංකේතනය කළ නාලිකාවක සිදු කෙරේ

Kafka සඳහා SSL/TLS සංකේතනය ක්‍රියා කරන ආකාරය සම්පූර්ණයෙන් අවබෝධ කර ගැනීමට, කරුණාකර නිල ලේඛන වෙත යොමු වන්න: docs.confluent.io/platform/current/kafka/encryption.html

SSL/TLS සහතිකය අවසන්view

සටහන: මෙම උපවගන්තියේදී අපි පහත පාරිභාෂිතය භාවිතා කරමු:

සහතිකය: සහතික අධිකාරියක් (CA) විසින් අත්සන් කරන ලද SSL සහතිකයක්. සෑම කෆ්කා තැරැව්කරුවකුටම එකක් ඇත.
යතුරු ගබඩාව: යතුරු ගබඩාව file සහතිකය ගබඩා කරන බව. යතුරු ගබඩාව file සහතිකයේ පුද්ගලික යතුර අඩංගු වේ; එබැවින් එය ආරක්ෂිතව තබා ගත යුතුය.
භාර ගබඩාව: ඒ file විශ්වාසනීය CA සහතික අඩංගු වේ.

පාලන මධ්‍යස්ථානයේ ක්‍රියාත්මක වන බාහිර සේවාලාභියෙකු සහ Kafka අතර සත්‍යාපනය සැකසීමට, CA මූල සහතිකය සමඟ සහතික අධිකාරියක් (CA) විසින් අත්සන් කරන ලද අදාළ සහතිකයක් සමඟින් අර්ථ දක්වා ඇති යතුරු ගබඩාවක් දෙපසම තිබිය යුතුය.
මීට අමතරව, සේවාලාභියාට CA මූල සහතිකය සහිත භාර ගබඩාවක් ද තිබිය යුතුය.
CA මූල සහතිකය Kafka තැරැව්කරුට සහ Kafka සේවාදායකයාට පොදු වේ.

අවශ්ය සහතික නිර්මාණය කිරීම
මෙය 17 පිටුවේ "උපග්‍රන්ථයේ" ආවරණය කර ඇත.

පාලන මධ්‍යස්ථානයේ Kafka Broker SSL/TLS වින්‍යාසය

සටහන: මෙම උපදෙස් පාලන මධ්‍යස්ථාන සේවාදායකයේ ක්‍රියාත්මක විය යුතුය.

සටහන: දිගටම කරගෙන යාමට පෙර, 17 වැනි පිටුවේ “ඇමුණුම” හි ඇති උපදෙස් අනුගමනය කිරීමෙන් ඔබ SSL සහතිකය අඩංගු යතුරු ගබඩාව සෑදිය යුතුය. පහත සඳහන් මාර්ග මෙම උපදෙස් වලින් පැමිණේ.
SSL යතුරු ගබඩාව යනු a file සමඟ තැටියේ ගබඩා කර ඇත file දිගුව .jks.

ඔබ Kafka තැරැව්කරු සහ Kafka සේවාදායකයා සඳහා අවශ්‍ය සහතික සෑදූ පසු, ඔබට පාලන මධ්‍යස්ථානයේ ක්‍රියාත්මක වන Kafka තැරැව්කරු වින්‍යාස කිරීමෙන් ඉදිරියට යා හැක. ඔබ පහත සඳහන් දෑ දැන සිටිය යුතුය:

: පාලන මධ්‍යස්ථානයේ පොදු සත්කාරක නාමය; මෙය Kafka සේවාදායකයින් විසින් විසඳිය හැකි සහ ප්‍රවේශ විය යුතුය.
: SSL සහතිකය සෑදීමේදී යතුරු ගබඩා මුරපදය ලබා දී ඇත.

සහ : මේවා ඔබට පිළිවෙලින් පරිපාලක සහ සේවාදායක පරිශීලකයා සඳහා සැකසීමට අවශ්‍ය මුරපද වේ. ex හි දක්වා ඇති පරිදි ඔබට තවත් පරිශීලකයින් එක් කළ හැකි බව සලකන්නample.

පහත දැක්වෙන ගුණාංග /etc/kafka/server.properties හි සංස්කරණය කරන්න හෝ එකතු කරන්න, පෙන්වා ඇති පරිදි ඉහත විචල්‍යයන් ඇතුළත් කරන්න:

අවවාදයයි: PLAINTEXT://localhost:9092 ඉවත් නොකරන්න; අභ්‍යන්තර සේවාවන්ට සන්නිවේදනය කිරීමට නොහැකි වන බැවින් මෙය පාලන මධ්‍යස්ථාන ක්‍රියාකාරිත්වය බිඳ දමනු ඇත.

…
# කෆ්කා තැරැව්කරු සවන් දෙන ලිපින.
සවන්දෙන්නන්=PLAINTEXT://localhost:9092,SASL_SSL://0.0.0.0:9093

# සම්බන්ධ වන ඕනෑම සේවාදායකයෙකු වෙත ආපසු ප්‍රචාරණය කරන ලද සත්කාරක මේවාය.
advertised.listeners=PLAINTEXT://localhost:9092,SASL_SSL:// :9093…
####### අභිරුචි වින්‍යාසය

# SSL වින්‍යාසය
ssl.endpoint.identification.algorithm=
ssl.keystore.location=/var/ssl/private/kafka.server.keystore.jks
ssl.keystore.password=

ssl.key.password=
ssl.client.auth=කිසිවක් නැත
ssl.protocol=TLSv1.2

# SASL වින්‍යාසය
sasl.enabled.mechanisms=PLAIN
පරිශීලක නාමය=”පරිපාලක” \

මුරපදය =" ”\
user_admin=” ”\
user_client=” ”;

# සටහන පරිශීලක_ සමඟ තවත් පරිශීලකයින් එකතු කළ හැකිය =
# අවසරය, ACL ක්‍රියාත්මක කරන්න
authorizer.class.name=kafka.security.authorizer.AclAuthorizer super.users=පරිශීලක:පරිපාලක

ප්‍රවේශ පාලන ලැයිස්තු (ACL) පිහිටුවීම

localhost මත ACL ක්‍රියාත්මක කිරීම

අවවාදයයි: අපි ප්‍රථමයෙන් දේශීය සත්කාරක සඳහා ACL පිහිටුවිය යුතුය, එවිට පාලන මධ්‍යස්ථානයට තවමත් Kafka වෙත ප්‍රවේශ විය හැක. මෙය සිදු නොකළහොත්, දේවල් බිඳ වැටෙනු ඇත.

–authorizer kafka.security.authorizer.AclAuthorizer \

–authorizer-properties zookeeper.connect=localhost:2181 \
-එකතු කරන්න -අවසර-ප්‍රධාන පරිශීලක: නිර්නාමික -අවසර-සත්කාරක 127.0.0.1 -පොකුරු
/usr/lib/kafka/bin/kafka-acls.sh \

–authorizer kafka.security.authorizer.AclAuthorizer \
–authorizer-properties zookeeper.connect=localhost:2181 \
-එකතු කරන්න -අවසර-ප්‍රධාන පරිශීලක: නිර්නාමික -අවසර-සත්කාරක 127.0.0.1 -මාතෘකාව '*'

/usr/lib/kafka/bin/kafka-acls.sh \
–authorizer kafka.security.authorizer.AclAuthorizer \
–authorizer-properties zookeeper.connect=localhost:2181 \

-එකතු කරන්න -අවසර-ප්‍රධාන පරිශීලක: නිර්නාමික -අවසර-සත්කාරක 127.0.0.1 -කණ්ඩායම '*'

බාහිර පරිශීලකයින්ට paa.public.* මාතෘකා කියවීමට අවසර ලැබෙන පරිදි, අපට බාහිර කියවීමට පමණක් ප්‍රවේශය සඳහා ACL සබල කිරීමට අවශ්‍ය වේ.

### නිර්නාමික පරිශීලකයින් සඳහා ACL ඇතුළත් කිරීම් /usr/lib/kafka/bin/kafka-acls.sh \

සටහන: වඩාත් සියුම් පාලනයක් සඳහා, කරුණාකර නිල කෆ්කා ලේඛන බලන්න.

–authorizer kafka.security.authorizer.AclAuthorizer \
–authorizer-properties zookeeper.connect=localhost:2181 \
-එකතු කරන්න -අවසර දෙන්න-ප්‍රධාන පරිශීලක:* -මෙහෙයුම් කියවීම -මෙහෙයවීම විස්තර කිරීම \ -කණ්ඩායම 'NCC'

/usr/lib/kafka/bin/kafka-acls.sh \
–authorizer kafka.security.authorizer.AclAuthorizer \
–authorizer-properties zookeeper.connect=localhost:2181 \

–add –allow-principal User:* –operation read –operation description \ –topic paa.public. -සම්පත්-රටා-වර්ගය උපසර්ගය

මෙය සිදු කළ පසු, ඔබ සේවාවන් නැවත ආරම්භ කළ යුතුය:

### බාහිර පරිශීලකයින් සඳහා ACL ඇතුළත් කිරීම් /usr/lib/kafka/bin/kafka-acls.sh \

sudo ncc සේවා නැවත ආරම්භ කරන්න

සේවාදායකයෙකුට ආරක්ෂිත සම්බන්ධතාවයක් ස්ථාපිත කළ හැකි බව තහවුරු කර ගැනීම සඳහා, පහත දැක්වෙන විධානය බාහිරව ක්‍රියාත්මක කරන්න
සේවාදායක පරිගණකය (පාලක මධ්‍යස්ථාන සේවාදායකයේ නොවේ). පහත, PUBLIC_HOSTNAME යනු පාලන මධ්‍යස්ථාන සත්කාරක නාමයයි:

openssl s_client -debug -connect ${PUBLIC_HOSTNAME}:9093 -tls1_2 | grep "ආරක්ෂිත නැවත සාකච්ඡා සඳහා සහය දක්වයි"

විධාන ප්‍රතිදානයේ ඔබ සේවාදායක සහතිකය මෙන්ම පහත දෑ ද දැකිය යුතුය:

ආරක්ෂිත නැවත සාකච්ඡා සඳහා සහය දක්වයි

අභ්‍යන්තර සේවාවන්ට Kafka සේවාදායකය වෙත ප්‍රවේශය ලබා දී ඇති බව සහතික කර ගැනීමට කරුණාකර පහත ලොගය පරීක්ෂා කරන්නfiles:

/var/log/kafka/server.log

/var/log/kafka/kafka-authorizer.log

බාහිර සේවාදායක සම්බන්ධතාව වලංගු කිරීම

kafkacat

සටහන: මෙම උපදෙස් ක්‍රියාත්මක කළ යුත්තේ සේවාදායක පරිගණකයක (පාලක මධ්‍යස්ථාන සේවාදායකයේ නොවේ).
සටහන: ප්‍රමිතික තොරතුරු සංදර්ශන කිරීමට, පාලන මධ්‍යස්ථානයේ අවම වශයෙන් එක් මොනිටරයක්වත් ක්‍රියාත්මක වන බව සහතික කර ගන්න.

බාහිර සේවාලාභියෙකු ලෙස සම්බන්ධතාව සත්‍යාපනය කිරීම සහ වලංගු කිරීම සඳහා, 4 පිටුවේ "පාලක මධ්‍යස්ථානයේ ප්‍රවාහ API ක්‍රියා කරන බව තහවුරු කිරීම" යන කොටසේ ස්ථාපනය කර ඇති kafkacat උපයෝගීතාව භාවිතා කළ හැකිය.
පහත පියවරයන් සිදු කරන්න:

සටහන: පහත, CLIENT_USER යනු කලින් සඳහන් කළ පරිශීලකයා වේ file පාලන මධ්‍යස්ථානයේ /etc/kafka/server.properties: එනම්, user_client සහ එහි පිහිටුවා ඇති මුරපදය.
සේවාදායක පැත්තේ SSL සහතිකය අත්සන් කිරීමට භාවිතා කරන CA මූල සහතිකය සේවාලාභියා මත තිබිය යුතුය.

නිර්මාණය කරන්න file පහත අන්තර්ගතය සහිත client.properties:

security.protocol=SASL_SSL
ssl.ca.location={PATH_TO_CA_CERT}
sasl.mechanisms=PLAIN
sasl.username={CLIENT_USER}
sasl.password={CLIENT_PASSWORD}

කොහෙද

{PATH_TO_CA_CERT} යනු Kafka තැරැව්කරු විසින් භාවිතා කරන CA මූල සහතිකයේ ස්ථානයයි
{CLIENT_USER} සහ {CLIENT_PASSWORD} යනු සේවාලාභියා සඳහා පරිශීලක අක්තපත්‍ර වේ.

kafkacat විසින් පරිභෝජනය කරන ලද පණිවිඩය බැලීමට පහත විධානය ක්‍රියාත්මක කරන්න:

අපනයනය KAFKA_FQDN=
අපනයනය METRICS_TOPIC=paa.public.accounts. .මිතික
kafkacat -b ${KAFKA_FQDN}:9093 -F client.properties -t ${METRICS_TOPIC} -C -e

මෙහි {METRICS_TOPIC} යනු "paa.public" උපසර්ගය සහිත කෆ්කා මාතෘකාවේ නමයි.

සටහන: kafkacat හි පැරණි අනුවාදයන් a වෙතින් සේවාදායක සැකසුම් කියවීම සඳහා -F විකල්පය ලබා නොදේ file. ඔබ එවැනි අනුවාදයක් භාවිතා කරන්නේ නම්, ඔබ පහත දැක්වෙන පරිදි විධාන රේඛාවෙන් එම සැකසුම් ලබා දිය යුතුය.

kafkacat -b ${KAFKA_FQDN}:9093 \

X security.protocol=SASL_SSL \
X ssl.ca.location={PATH_TO_CA_CERT} \
X sasl.mechanisms=PLAIN \
X sasl.username={CLIENT_USER} \
X sasl.password={CLIENT_PASSWORD} \
t ${METRICS_TOPIC} -C -e

සම්බන්ධතාවය නිදොස් කිරීම සඳහා, ඔබට -d විකල්පය භාවිතා කළ හැක:

පාරිභෝගික සන්නිවේදනයන් දෝෂහරණය කරන්න
kafkacat -d පාරිභෝගික -b ${KAFKA_FQDN}:9093 -F client.properties -t ${METRICS_TOPIC} -C -e
# තැරැව්කාර සන්නිවේදනයන් දෝෂහරණය කරන්න
kafkacat -d broker -b ${KAFKA_FQDN}:9093 -F client.properties -t ${METRICS_TOPIC} -C -e

භාවිතා කරන Kafka සේවාලාභී පුස්තකාලය සඳහා ප්‍රලේඛනය වෙත යොමු වීමට වග බලා ගන්න, ගුණාංග client.properties වල තිබෙන ඒවාට වඩා වෙනස් විය හැක.

පණිවිඩ ආකෘතිය
ප්‍රමිතික සහ පාර-දත්ත මාතෘකා සඳහා භාවිතා කරන පණිවිඩ ප්‍රොටෝකෝල බෆර (protobuf) ආකෘතියෙන් අනුක්‍රමික වේ (බලන්න developers.google.com/protocol-buffers) මෙම පණිවිඩ සඳහා වන යෝජනා ක්‍රම පහත ආකෘතියට අනුගත වේ:

Metrics Protobuf Schema

syntax = "proto3";
"google/protobuf/timest ආයාත කරන්නamp.ප්රෝටෝ";
පැකේජය paa.streamingapi;
විකල්පය go_package = ".;paa_streamingapi";
පණිවිඩ මිතික {
google.protobuf.Timestamp timestamp = 1;
සිතියම අගයන් = 2;
int32 stream_id = 3;
}
/**
* මෙට්‍රික් අගයක් පූර්ණ සංඛ්‍යාවක් හෝ float එකක් විය හැක.
*/
පණිවිඩ MetricValue {
{ වර්ගයේ එකක්
int64 int_val = 1;
පාවෙන float_val = 2;
}
}

පාරදත්ත Protobuf යෝජනා ක්රමය

syntax = "proto3";
පැකේජය paa.streamingapi;
විකල්පය go_package = ".;paa_streamingapi";
පණිවිඩ පාරදත්ත {
int32 stream_id = 1;
string stream_name = 2;
සිතියම tags = 13;
}

සේවාලාභියා හිටපුamples

සටහන: මෙම විධාන බාහිර සේවාලාභියෙකු මත ධාවනය කිරීමට අදහස් කෙරේ, උදාහරණයක් ලෙසampඔබේ ලැප්ටොප් පරිගණකය හෝ ඒ හා සමාන, සහ පාලන මධ්‍යස්ථානයේ නොවේ.
සටහන: ප්‍රමිතික තොරතුරු සංදර්ශන කිරීමට, පාලන මධ්‍යස්ථානයේ අවම වශයෙන් එක් මොනිටරයක්වත් ක්‍රියාත්මක වන බව සහතික කර ගන්න.

පාලන මධ්‍යස්ථාන තාරබෝලයට paa-streaming-api-client-ex සංරක්ෂිතය ඇතුළත් වේamples.tar.gz (සේවාදායක-උදාamples), එහි හිටපු එකක් අඩංගු වේample Python පිටපත Streaming API භාවිතා කරන ආකාරය පෙන්වයි.

සේවාලාභියා ස්ථාපනය කිරීම සහ වින්‍යාස කිරීම Examples
ඔබ සේවාදායකයා හිටපු සොයා ගනීampපැරගන් ඇක්ටිව් ඇෂුවරන්ස් පාලන මධ්‍යස්ථාන ෆෝල්ඩරයේ les:

අපනයනය CC_VERSION=4.1.0
cd ./paa-control-center_${CC_VERSION}
ls paa-streaming-api-client-examples*

client-ex ස්ථාපනය කිරීමටampඔබගේ බාහිර සේවාදායක පරිගණකයේ les, පහත පරිදි ඉදිරියට යන්න:

# හිටපු සේවාදායකයාගේ අන්තර්ගතය උපුටා ගැනීම සඳහා නාමාවලිය සාදන්නamples tarball
mkdir paa-streaming-api-client-examples
# හිටපු සේවාදායකයාගේ අන්තර්ගතය උපුටා ගන්නamples tarball
tar xzf paa-streaming-api-client-examples.tar.gz -C paa-streaming-api-client-examples
# අලුතින් සාදන ලද නාමාවලිය වෙත යන්න
cd paa-streaming-api-client-examples

සේවාදායකයා-examples ධාවනය කිරීමට Docker අවශ්‍ය වේ. Docker සඳහා බාගැනීම් සහ ස්ථාපන උපදෙස් මෙහි සොයා ගත හැක https://docs.docker.com/engine/install.

Client Ex භාවිතා කිරීමamples
සේවාදායකයා - හිටපුamples මෙවලම් ex ගොඩනැගීමට මූලික හෝ උසස් ආකාරයෙන් ධාවනය කළ හැකampවිවිධ සංකීර්ණත්වය. අවස්ථා දෙකේදීම, හිටපු ධාවනය කිරීමටද හැකියampවින්යාසයක් සහිත les file සේවාදායක පාර්ශවයේ තවදුරටත් අභිරුචිකරණය සඳහා අමතර ගුණාංග අඩංගු වේ.

මූලික මාදිලිය
මූලික ප්‍රකාරයේදී, ප්‍රමිතික සහ ඒවායේ පාරදත්ත වෙන වෙනම ප්‍රවාහ කෙරේ. මේ සඳහා, සේවාදායකයා බාහිර ප්‍රවේශය සඳහා ලබා ගත හැකි සෑම කෆ්කා මාතෘකාවකටම සවන් දෙන අතර ලැබුණු පණිවිඩ කොන්සෝලයට මුද්‍රණය කරයි.
මූලික හිටපු ක්‍රියාත්මක කිරීම ආරම්භ කිරීමටamples, ධාවනය:

build.sh run-basic –kafka-brokers localhost:9092 –ගිණුම ACCOUNT_SHORTNAME

ACCOUNT_SHORTNAME යනු ඔබට ප්‍රමිතික ලබා ගැනීමට අවශ්‍ය ගිණුමේ කෙටි නමයි.
හිටපු අයව ක්‍රියාත්මක කිරීම අවසන් කිරීමටample, Ctrl + C ඔබන්න. (සේවාදායකයා කල් ඉකුත් වීමේ සිදුවීමක් සඳහා රැඳී සිටින නිසා ක්‍රියාත්මක කිරීම නැවැත්වීමට පෙර සුළු ප්‍රමාදයක් ඇති විය හැක.)

උසස් මාදිලිය

සටහන: පාලන මධ්‍යස්ථානයේ ක්‍රියාත්මක වන HTTP මොනිටර සඳහා පමණක් ප්‍රමිතික දර්ශනය වේ.

උසස් මාදිලියේ ක්‍රියාත්මක කිරීම ප්‍රමිතික සහ පාරදත්ත පණිවිඩ අතර සහසම්බන්ධය පෙන්වයි. මෙය
අනුරූප පාර-දත්ත පණිවිඩයට යොමු වන ප්‍රවාහ හැඳුනුම් ක්ෂේත්‍රයක එක් එක් ප්‍රමිතික පණිවිඩයේ තිබීමට ස්තූතිවන්ත විය හැකිය.
උසස් හිටපු ක්‍රියාත්මක කිරීමටamples, ධාවනය:

build.sh run-advanced –kafka-brokers localhost:9092 –ගිණුම ACCOUNT_SHORTNAME

අතිරේක සැකසුම්
හිටපු එක දුවන්න පුළුවන්amp-config- භාවිතා කරන සේවාලාභියාගේ අමතර වින්‍යාසය සහිත lesfile විකල්පය පසුව a file key=value පෝරමයේ ගුණාංග අඩංගු නම.

build.sh ධාවන-උසස් \
–kafka-brokers localhost:9092 \
-ගිණුම ACCOUNT_SHORTNAME \
-config-file client_config.properties

සටහන: සියල්ල fileඉහත විධානයේ සඳහන් කර ඇති s වත්මන් නාමාවලියෙහි පිහිටා තිබිය යුතු අතර සාපේක්ෂ මාර්ග පමණක් භාවිතා කර යොමු කළ යුතුය. මෙය -config- යන දෙකටම අදාළ වේ.file තර්කය සහ වින්‍යාසයේ ඇති සියලුම ඇතුළත් කිරීම් වලට file බව විස්තර කරයි file ස්ථාන.

බාහිර සේවාදායක සත්‍යාපනය වලංගු කිරීම
Client-ex භාවිතයෙන් පාලන මධ්‍යස්ථානයෙන් පිටත සිට සේවාදායක සත්‍යාපනය වලංගු කිරීමටamples, පහත පියවර සිදු කරන්න:

Paragon Active Assurance Control Center ෆෝල්ඩරයෙන්, paa-streaming-api-client-ex වෙත මාරු වන්නamples ෆෝල්ඩරය:

cd paa-streaming-api-client-examples

CA මූල සහතිකය ca-cert වත්මන් නාමාවලියට පිටපත් කරන්න.
සේවාදායකයකු සාදන්න.ගුණාංග file පහත අන්තර්ගතය සමඟ:

security.protocol=SASL_SSL ssl.ca.location=ca-cert
sasl.mechanism=PLAIN
sasl.username={CLIENT_USER}
sasl.password={CLIENT_PASSWORD}

එහිදී {CLIENT_USER} සහ {CLIENT_PASSWORD} සේවාලාභියා සඳහා පරිශීලක අක්තපත්‍ර වේ.

මූලික ex ධාවනය කරන්නamples:

අපනයනය KAFKA_FQDN=
build.sh run-basic –kafka-brokers ${KAFKA_FQDN}:9093 \
-ගිණුම ACCOUNT_SHORTNAME
-config-file සේවාදායකයා.දේපළ

ACCOUNT_SHORTNAME යනු ඔබට ප්‍රමිතික ලබා ගැනීමට අවශ්‍ය ගිණුමේ කෙටි නමයි.

උසස් හිටපු ධාවනය කරන්නamples:

අපනයනය KAFKA_FQDN=
build.sh run-advanced –kafka-brokers ${KAFKA_FQDN}:9093 \
-ගිණුම ACCOUNT_SHORTNAME
-config-file සේවාදායකයා.දේපළ

උපග්රන්ථය

මෙම උපග්රන්ථයේ අපි නිර්මාණය කරන්නේ කෙසේද යන්න විස්තර කරමු:

යතුරු ගබඩාවක් file Kafka තැරැව්කාර SSL සහතිකය ගබඩා කිරීම සඳහා
භාර ගබඩාවක් file කෆ්කා තැරැව්කාර සහතිකය අත්සන් කිරීමට භාවිතා කරන සහතික අධිකාරිය (CA) මූල සහතිකය ගබඩා කිරීම සඳහා.

කෆ්කා තැරැව්කාර සහතිකයක් නිර්මාණය කිරීම
සැබෑ සහතික අධිකාරියක් භාවිතා කරමින් සහතිකයක් නිර්මාණය කිරීම (නිර්දේශිත)
ඔබ විශ්වාසවන්ත CA වෙතින් සැබෑ SSL සහතිකයක් ලබා ගැනීම නිර්දේශ කෙරේ.
ඔබ CA තීරණය කළ පසු, ඔවුන්ගේ CA මූල සහතිකය ca-cert පිටපත් කරන්න file පහත දැක්වෙන පරිදි ඔබේම මාර්ගයට:

අපනයනය CA_PATH=~/my-ca
mkdir ${CA_PATH}
cp ca-cert ${CA_PATH}

ඔබේම සහතික අධිකාරියක් සාදන්න

සටහන: සාමාන්‍යයෙන් ඔබ ඔබේ සහතිකය සැබෑ සහතික අධිකාරියකින් අත්සන් කර තිබිය යුතුය; පෙර උපවගන්තිය බලන්න. පහත දැක්වෙන්නේ හිටපු කෙනෙක් පමණයිample.

මෙන්න අපි අපේම සහතික අධිකාරිය (CA) මූල සහතිකය නිර්මාණය කරමු file දින 999 සඳහා වලංගු වේ (නිෂ්පාදනයේදී නිර්දේශ නොකරයි):

# CA ගබඩා කිරීම සඳහා නාමාවලියක් සාදන්න
අපනයනය CA_PATH=~/my-ca
mkdir ${CA_PATH}
# CA සහතිකය ජනනය කරන්න
openssl req -new -x509 -keyout ${CA_PATH}/ca-key-out ${CA_PATH}/ca-cert -days 999

Client Truststore නිර්මාණය කිරීම
දැන් ඔබට විශ්වාස ගබඩාවක් නිර්මාණය කළ හැකිය file ඉහත ජනනය කරන ලද ca-cert අඩංගු වේ. මෙය file Streaming API වෙත ප්‍රවේශ වන Kafka සේවාලාභියාට අවශ්‍ය වනු ඇත:

keytool -keystore kafka.client.truststore.jks \
- අන්වර්ථය CARoot \
- ආනයනකරු -file ${CA_PATH}/ca-cert

දැන් CA සහතිකය භාර ගබඩාවේ ඇති බැවින්, සේවාදායකයා එය සමඟ අත්සන් කර ඇති ඕනෑම සහතිකයක් විශ්වාස කරයි.
ඔබ පිටපත් කළ යුතුය file kafka.client.truststore.jks ඔබගේ සේවාදායක පරිගණකයේ දන්නා ස්ථානයකට ගොස් එය සැකසීම් වෙත යොමු කරන්න.

කෆ්කා තැරැව්කරු සඳහා යතුරු ගබඩාව නිර්මාණය කිරීම
Kafka තැරැව්කරු SSL සහතිකය සහ පසුව kafka.server.keystore.jks යතුරු ගබඩාව උත්පාදනය කිරීමට, පහත පරිදි ඉදිරියට යන්න:

SSL සහතිකය ජනනය කිරීම
පහතින්, 999 යනු යතුරු ගබඩාවේ වලංගු දින ගණන වන අතර FQDN යනු සේවාලාභියාගේ සම්පූර්ණ සුදුසුකම් ලත් වසම් නාමයයි (නෝඩයේ පොදු සත්කාරක නාමය).

සටහන: කෆ්කා සේවාලාභියා පාලන මධ්‍යස්ථානයට සම්බන්ධ වීමට භාවිතා කරන නියම ධාරක නාමයට FQDN ගැලපීම වැදගත් වේ.

sudo mkdir -p /var/ssl/private
sudo chown -R $USER: /var/ssl/private
cd /var/ssl/private
අපනයනය FQDN= keytool -keystore kafka.server.keystore.jks \
- අන්වර්ථ සේවාදායකය \
- වලංගුභාවය 999 \
– genkey -keyalg RSA -ext SAN=dns:${FQDN}

සහතික අත්සන් කිරීමේ ඉල්ලීමක් සාදා එය ගබඩා කරන්න file නම් කර ඇති cert-server-request:

keytool -keystore kafka.server.keystore.jks \
- - අන්වර්ථ සේවාදායකය \
- - සහතිකය \
- – file cert-server-request

ඔබ දැන් යැවිය යුතුය file cert-server-request to your Certificate Authority (CA) ඔබ භාවිතා කරන්නේ සැබෑ එකක් නම්. එවිට ඔවුන් අත්සන් කළ සහතිකය ආපසු ලබා දෙනු ඇත. අපි මෙය පහත cert-server-signed ලෙස සඳහන් කරන්නෙමු.

ස්වයං-සාදන ලද CA සහතිකයක් භාවිතා කරමින් SSL සහතිකය අත්සන් කිරීම

සටහන: නැවතත්, නිෂ්පාදන පද්ධතියක ඔබේම CA භාවිතා කිරීම නිර්දේශ නොකරයි.

CA භාවිතා කර සහතිකය අත්සන් කරන්න file cert-server-request, එය අත්සන් කරන ලද සහතිකය නිෂ්පාදනය කරයි cert-server-signed. පහත බලන්න; ca-password යනු CA සහතිකය නිර්මාණය කිරීමේදී සැකසූ මුරපදයයි.

cd /var/ssl/private openssl x509 -req \
- – CA ${CA_PATH}/ca-cert \
- – කේක් ${CA_PATH}/ca-key \
- - සහතික-සේවාදායක-ඉල්ලීම තුළ \
- - සහතික-සේවාදායකය අත්සන් කර ඇත \
- – දින 999 -CAcreateserial \
- – passin pass:{ca-password}

අත්සන් කළ සහතිකය යතුරු ගබඩාවට ආයාත කිරීම

ca-cert මූල සහතිකය යතුරු ගබඩාවට ආයාත කරන්න:

keytool -keystore kafka.server.keystore.jks \
- - අන්වර්ථ ca-cert \
- - ආනයන \
- – file ${CA_PATH}/ca-cert

cert-server-signed ලෙස සඳහන් වන අත්සන් කළ සහතිකය ආයාත කරන්න:

keytool -keystore kafka.server.keystore.jks \
- - අන්වර්ථ සේවාදායකය \
- - ආනයන \
- – file cert-server-signed

ද file kafka.server.keystore.jks පාලන මධ්‍යස්ථාන සේවාදායකයේ දන්නා ස්ථානයකට පිටපත් කළ යුතු අතර, පසුව /etc/kafka/server.properties වෙත යොමු කළ යුතුය.

Streaming API භාවිතා කිරීම

මෙම කොටසේ

ජෙනරාල් | 20
කෆ්කා මාතෘකා නම් | 21
Exampප්‍රවාහ API භාවිතා කිරීම අඩුයි | 21

ජෙනරාල්
ප්‍රවාහ API පරීක්ෂණ සහ මොනිටර දත්ත දෙකම ලබා ගනී. මෙම වර්ග වලින් එකක් වෙන්කර හඳුනාගත නොහැක.
ප්‍රවාහය API විසින් ඊතර්නෙට් සේවා සක්‍රීය කිරීමේ පරීක්ෂණ සහ විනිවිදභාවය පරීක්ෂණ වැනි ස්ක්‍රිප්ට්-පාදක පරීක්ෂණ (පාලක මධ්‍යස්ථාන GUI හි ජිග්සෝ කැබැල්ලක් වෙනුවට සෘජුකෝණාස්‍රයකින් නියෝජනය වන) දත්ත ලබා නොගනී.

කෆ්කා මාතෘකා නම්
ප්‍රවාහ API සඳහා Kafka මාතෘකා නම් පහත පරිදි වේ, %s යනු පාලන මධ්‍යස්ථාන ගිණුමේ කෙටි නමයි (ගිණුම සෑදීමේදී දක්වනු ලැබේ):

අඛණ්ඩව (
අපනයනකරුගේ නම = "කෆ්කා"
metadataTopicTpl = “paa.public.accounts.%s.metadata” metricsTopicTpl = “paa.public.accounts.%s.metrics” )

Exampප්‍රවාහ API භාවිතා කිරීම අඩුයි
හිටපුampපහත දැක්වෙන les tarball paa-streaming-api-client-ex හි දක්නට ලැබේamples.tar.gz පාලන මධ්‍යස්ථාන තාරබෝල තුළ අඩංගු වේ.
මුලින්ම, මූලික හිටපු කෙනෙක් ඉන්නවාample ප්‍රමිතික සහ ඒවායේ පාර-දත්ත වෙන වෙනම ප්‍රවාහ කරන ආකාරය සහ ලැබුණු පණිවිඩ කොන්සෝලයට මුද්‍රණය කරන ආකාරය නිරූපණය කරයි. ඔබට එය පහත පරිදි ධාවනය කළ හැකිය:

sudo ./build.sh run-basic –kafka-brokers localhost:9092 –ගිණුම ACCOUNT_SHORTNAME

ඊට වඩා දියුණු හිටපු එකකුත් ඉන්නවාampප්‍රමිතික සහ පාරදත්ත පණිවිඩ සහසම්බන්ධිත le. එය ක්‍රියාත්මක කිරීමට මෙම විධානය භාවිතා කරන්න:

sudo ./build.sh run-advanced –kafka-brokers localhost:9092 –ගිණුම ACCOUNT_SHORTNAME

ඉහත ආකාරයට Docker විධාන ක්‍රියාත්මක කිරීමට ඔබ sudo භාවිතා කළ යුතුය. විකල්පයක් ලෙස, ඔබට sudo නොමැතිව Docker විධානයන් ක්‍රියාත්මක කිරීමට Linux පසු ස්ථාපන පියවර අනුගමනය කළ හැක. විස්තර සඳහා, යන්න docs.docker.com/engine/install/linux-postinstall.

Juniper Networks, Juniper Networks ලාංඡනය, Juniper සහ Junos යනු එක්සත් ජනපදයේ සහ අනෙකුත් රටවල Juniper Networks, Inc. හි ලියාපදිංචි වෙළඳ ලකුණු වේ. අනෙකුත් සියලුම වෙළඳ ලකුණු, සේවා ලකුණු, ලියාපදිංචි ලකුණු, හෝ ලියාපදිංචි සේවා ලකුණු ඔවුන්ගේ අයිතිකරුවන්ගේ දේපළ වේ. Juniper Networks මෙම ලේඛනයේ කිසියම් සාවද්‍යතාවයක් සඳහා කිසිදු වගකීමක් භාර නොගනී. දැනුම්දීමකින් තොරව මෙම ප්‍රකාශනය වෙනස් කිරීමට, වෙනස් කිරීමට, මාරු කිරීමට හෝ වෙනත් ආකාරයකින් සංශෝධනය කිරීමට Juniper Networks හට අයිතිය ඇත. ප්‍රකාශන හිමිකම © 2023 Juniper Networks, Inc. සියලුම හිමිකම් ඇවිරිණි.

ලේඛන / සම්පත්

Juniper NETWORKS Streaming API මෘදුකාංගය [pdf] පරිශීලක මාර්ගෝපදේශය
Streaming API මෘදුකාංග, API මෘදුකාංග, මෘදුකාංග

යොමු කිරීම්

පරිශීලක අත්පොත

Juniper NETWORKS Streaming API මෘදුකාංගය

නිෂ්පාදන තොරතුරු

හැඳින්වීම

බාහිර සත්කාරක සඳහා Kafka විවෘත කිරීම

ප්‍රවේශ පාලන ලැයිස්තු (ACL) පිහිටුවීම

### නිර්නාමික පරිශීලකයින් සඳහා ACL ඇතුළත් කිරීම් /usr/lib/kafka/bin/kafka-acls.sh \

### බාහිර පරිශීලකයින් සඳහා ACL ඇතුළත් කිරීම් /usr/lib/kafka/bin/kafka-acls.sh \

බාහිර සේවාදායක සම්බන්ධතාව වලංගු කිරීම

උපග්රන්ථය

Streaming API භාවිතා කිරීම

ලේඛන / සම්පත්

යොමු කිරීම්

කමෙන්ට් එකක් දාන්න

පිළිතුර අවලංගු කරන්න