代码之家 › 专栏 › 技术社区 › Olahzzz

如何在linux中将kafka用户日志写入文件

apache-kafka logging bash linux

Olahzzz · 技术社区 · 5 年前

但当我执行“echo‘test’|>>text.txt”时,会生成一个文件。

请帮忙。

./kafka-console-consumer.sh --bootstrap-server server1.server.com:9092, server2.server.com:9092, server3.server.com:9092 --topic MY-SAMPLE-TOPIC >> my_log_file.txt

1 回复 | 直到 5 年前

OneCricketeer Gabriele Mariotti 5 年前

你应该用卡夫卡连接。。。控制台使用者在不给使用者组的情况下不会跟踪偏移量

bin/connect-standalone config/connect-standalone.properties config/file-sink.properties

OneCricketeer Gabriele Mariotti 5 年前

默认情况下,kafka-console-consumer.sh从最新偏移量读取数据。因此,您必须在kafka控制台使用者工作期间继续发送数据。如果您想从头开始阅读,可以使用此命令(它将处理多达100条消息,因为 --max-messages 参数):

./kafka-console-consumer.sh --bootstrap-server server1.server.com:9092, server2.server.com:9092, server3.server.com:9092 --from-beginning --max-messages 100 --topic MY-SAMPLE-TOPIC >> my_log_file.txt

--offset x --partition y 从特定偏移量使用的参数。

推荐文章

Abdullah Chaudhry · json文件上的文件旋转和删除

2 年前

Patrick · 即使此时我没有实现日志语句,控制台输出中的错误日志从何而来?

2 年前

twisted · 将apache2 CustomLog管道传输到以其他用户身份运行的程序

3 年前

Max S · 如何从CMD读取日志的所有输出

7 年前

Ivan Denchev · Apache-过去一小时的日志

7 年前

Ev3rlasting · 在Logback[重复]中重写从根目录继承的记录器的附加程序

7 年前

ninja.coder · Log4j中的字符串串联性能

7 年前

Rich · 如何记录日志。是否与操作员一起调试?

7 年前

Matthew Flynn · 在运行Asp的Webapi 2上使用Serilog创建ILogger。净核心2

7 年前

EliteRaceElephant · 为什么ChromeDriver一直记录到控制台?

7 年前