рдЕрдВрдЧреНрд░реЗрдЬрд╝реАрдлреНрд░реЗрдВрдЪрд╕реНрдкреЗрдирд┐рд╢

Ad


рдСрдирд╡рд░реНрдХреНрд╕ рдлрд╝реЗрд╡рд┐рдХреЙрди

kafkacat - рдХреНрд▓рд╛рдЙрдб рдореЗрдВ рдСрдирд▓рд╛рдЗрди

рдЙрдмрдВрдЯреВ рдСрдирд▓рд╛рдЗрди, рдлреЗрдбреЛрд░рд╛ рдСрдирд▓рд╛рдЗрди, рд╡рд┐рдВрдбреЛрдЬ рдСрдирд▓рд╛рдЗрди рдПрдореБрд▓реЗрдЯрд░ рдпрд╛ рдореИрдХ рдУрдПрд╕ рдСрдирд▓рд╛рдЗрди рдПрдореБрд▓реЗрдЯрд░ рдкрд░ рдСрдирд╡рд░реНрдХреНрд╕ рдореБрдлреНрдд рд╣реЛрд╕реНрдЯрд┐рдВрдЧ рдкреНрд░рджрд╛рддрд╛ рдореЗрдВ рдХрд╛рдлреНрдХрд╛рдХреИрдЯ рдЪрд▓рд╛рдПрдВ

рдпрд╣ рдХрдорд╛рдВрдб kafkacat рд╣реИ рдЬрд┐рд╕реЗ рд╣рдорд╛рд░реЗ рдХрдИ рдореБрдлреНрдд рдСрдирд▓рд╛рдЗрди рд╡рд░реНрдХрд╕реНрдЯреЗрд╢рди рдЬреИрд╕реЗ рдЙрдмрдВрдЯреВ рдСрдирд▓рд╛рдЗрди, рдлреЗрдбреЛрд░рд╛ рдСрдирд▓рд╛рдЗрди, рд╡рд┐рдВрдбреЛрдЬ рдСрдирд▓рд╛рдЗрди рдПрдореБрд▓реЗрдЯрд░ рдпрд╛ рдореИрдХ рдУрдПрд╕ рдСрдирд▓рд╛рдЗрди рдПрдореБрд▓реЗрдЯрд░ рдХрд╛ рдЙрдкрдпреЛрдЧ рдХрд░рдХреЗ рдСрдирд╡рд░реНрдХреНрд╕ рдлреНрд░реА рд╣реЛрд╕реНрдЯрд┐рдВрдЧ рдкреНрд░рджрд╛рддрд╛ рдореЗрдВ рдЪрд▓рд╛рдпрд╛ рдЬрд╛ рд╕рдХрддрд╛ рд╣реИред

рдХрд╛рд░реНрдпрдХреНрд░рдо:

рдирд╛рдо


kafkacat - рдЕрдкрд╛рдЪреЗ рдХрд╛рдлреНрдХрд╛ рдХреЗ рд▓рд┐рдП рд╕рд╛рдорд╛рдиреНрдп рдирд┐рд░реНрдорд╛рддрд╛ рдФрд░ рдЙрдкрднреЛрдХреНрддрд╛

SYNOPSIS


kafkacat -C | -P | -L -t рд╡рд┐рд╖рдп [-p рд╡рд┐рднрд╛рдЬрди] -b рджрд▓рд╛рд▓реЛрдВ [, ...] [-D рдкрд░рд┐рд╕реАрдордХ] [-K рдкрд░рд┐рд╕реАрдордХ]
[-c cnt] [-X рд╕реВрдЪреА] [-X рдкреНрд░реЛрдк=рд╡реИрд▓] [-X рдлреЗрдВрдХрдирд╛] [-d DBG [, ...]] [-q] [-v] [-Z]
[рд╡рд┐рд╢рд┐рд╖реНрдЯ рд╡рд┐рдХрд▓реНрдк]
kafkacat -C [рд╕рд╛рдорд╛рдиреНрдп рд╡рд┐рдХрд▓реНрдк] [-o рдУрдлрд╝реНрд╕реЗрдЯ] [-e] [-O] [-u] [-J] [-f fmtstr]
kafkacat -P [рд╕рд╛рдорд╛рдиреНрдп рд╡рд┐рдХрд▓реНрдк] [-z рддреЗрдЬрд╝ | gzip] [-p -1] [рдкрдЯреНрдЯрд┐рдХрд╛ [...]]
kafkacat -L [рд╕рд╛рдорд╛рдиреНрдп рд╡рд┐рдХрд▓реНрдк] [-t рд╡рд┐рд╖рдп]

рд╡рд░реНрдгрди


kafkacat рдЕрдкрд╛рдЪреЗ рдХрд╛рдлреНрдХрд╛ 0.8 рдХреЗ рд▓рд┐рдП рдПрдХ рд╕рд╛рдорд╛рдиреНрдп рдЧреИрд░-рдЬреЗрд╡реАрдПрдо рдирд┐рд░реНрдорд╛рддрд╛ рдФрд░ рдЙрдкрднреЛрдХреНрддрд╛ рд╣реИ, рдЗрд╕реЗ рдПрдХ рдХреЗ рд░реВрдк рдореЗрдВ рд╕реЛрдЪреЗрдВ
рдХрд╛рдлреНрдХрд╛ рдХреЗ рд▓рд┐рдП рдиреЗрдЯрдХреИрдЯред

рдирд┐рд░реНрдорд╛рддрд╛ рдореЛрдб рдореЗрдВ ( -P ), kafkacat stdin рд╕реЗ рд╕рдВрджреЗрд╢реЛрдВ рдХреЛ рдкрдврд╝рддрд╛ рд╣реИ, рдПрдХ рд╡рд┐рдиреНрдпрд╛рд╕ рдпреЛрдЧреНрдп рдХреЗ рд╕рд╛рде рд╕реАрдорд╛рдВрдХрд┐рдд
рдбрд┐рд▓реАрдореАрдЯрд░ рдФрд░ рдЙрдиреНрд╣реЗрдВ рджрд┐рдП рдЧрдП рдХрд╛рдлреНрдХрд╛ рдХреНрд▓рд╕реНрдЯрд░, рд╡рд┐рд╖рдп рдФрд░ рд╡рд┐рднрд╛рдЬрди рдореЗрдВ рдЙрддреНрдкрдиреНрди рдХрд░рддрд╛ рд╣реИред рдЙрдкрднреЛрдХреНрддрд╛ рдореЗрдВ
рдореЛрдб ( -C ), kafkacat рдХрд┐рд╕реА рд╡рд┐рд╖рдп рдФрд░ рд╡рд┐рднрд╛рдЬрди рд╕реЗ рд╕рдВрджреЗрд╢реЛрдВ рдХреЛ рдкрдврд╝рддрд╛ рд╣реИ рдФрд░ рдЙрдиреНрд╣реЗрдВ stdout рдкрд░ рдкреНрд░рд┐рдВрдЯ рдХрд░рддрд╛ рд╣реИ
рдХреЙрдиреНрдлрд╝рд┐рдЧрд░ рдХрд┐рдП рдЧрдП рд╕рдВрджреЗрд╢ рд╕реАрдорд╛рдВрдХрдХ рдХрд╛ рдЙрдкрдпреЛрдЧ рдХрд░рдирд╛ред

рдпрджрд┐ рди рддреЛ -P or -C рдирд┐рд░реНрджрд┐рд╖реНрдЯ рд╣реИрдВ kafkacat рд╕реНрд╡рдЪрд╛рд▓рд┐рдд рд░реВрдк рд╕реЗ рдореЛрдб рдХрд╛ рдкрддрд╛ рд▓рдЧрд╛рдиреЗ рдХрд╛ рдкреНрд░рдпрд╛рд╕ рдХрд░рддрд╛ рд╣реИ
stdin/stdout tty рдкреНрд░рдХрд╛рд░реЛрдВ рдкрд░ рдЖрдзрд╛рд░рд┐рддред

kafkacat рдЗрд╕рдореЗрдВ рдореЗрдЯрд╛рдбреЗрдЯрд╛ рд╕реВрдЪреА рдореЛрдб рднреА рд╢рд╛рдорд┐рд▓ рд╣реИ ( -L ), рдХреА рд╡рд░реНрддрдорд╛рди рд╕реНрдерд┐рддрд┐ рдкреНрд░рджрд░реНрд╢рд┐рдд рдХрд░рдиреЗ рдХреЗ рд▓рд┐рдП
рдХрд╛рдлреНрдХрд╛ рдХреНрд▓рд╕реНрдЯрд░ рдФрд░ рдЙрд╕рдХреЗ рд╡рд┐рд╖рдп рдФрд░ рд╡рд┐рднрд╛рдЬрдиред

onworks.net рд╕реЗрд╡рд╛рдУрдВ рдХрд╛ рдЙрдкрдпреЛрдЧ рдХрд░рдХреЗ kafkacat рдХрд╛ рдСрдирд▓рд╛рдЗрди рдЙрдкрдпреЛрдЧ рдХрд░реЗрдВ


рдлреНрд░реА рд╕рд░реНрд╡рд░ рдФрд░ рд╡рд░реНрдХрд╕реНрдЯреЗрд╢рди

рд╡рд┐рдВрдбреЛрдЬ рдФрд░ рд▓рд╛рдЗрдиреЗрдХреНрд╕ рдПрдк рдбрд╛рдЙрдирд▓реЛрдб рдХрд░реЗрдВ

рд▓рд┐рдирдХреНрд╕ рдХрдорд╛рдВрдб

Ad