wangchaoforever

Results 5 comments of wangchaoforever

How to verify compress type of the message in a topic?

I know pykafka has a consumer attributes named `.compression_type`. It can help me to verify the producer's compress type. Does kafka-python has a similar comsumer attributes?

Hope the in_tail Input plugin support limit multiline log's size

@kenhys I upgrade my fluentd to v1.14.4 and use `max_line_size ` in tail, but the OOM KILL still happend. The logs: ```shell ... 2022-03-22 15:36:03 +0800 [info]: starting fluentd-1.14.4 pid=6603...

Fluentd in_tail "unreadable" file causes "following tail of <file>" to stop and no logs pushed

@ashie Is this one fixed?

Failed to validate connection org.mariadb.jdbc.MariaDbConnection (Connection.setNetworkTimeout cannot be called on a closed connection).

what is the real reson of this issue?

Something is broken in your `create_fn` (K8s version 1.28.2)

@tgrushka I also have this issue. I try to add `matchNamespace` in my yaml file and it works fine.But i don't know why. So you can have a try to...