wincent

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 wincentkafka服务器磁盘被logs日志占满该如何处理? 中 :

    可以自行修改kafka默认的日志输出策略:

    /config/log4j.properties
    
    1年前
  • wincent 回复 半兽人kafka服务器磁盘被logs日志占满该如何处理? 中 :

    这些个运行日志只能手动删除吗?没有像数据日志那样,定时自动删除的配置吗?

    1年前
  • wincent 回复 半兽人librdkafka消费一段时间后报错REQTMOUT...Timed out FetchRequest in flight 中 :

    仍未解决,消费组的消费详情如下:

    [root@host-192-168-246-144 kafka_2.12-2.6.0]# ./bin/kafka-consumer-groups.sh --bootstrap-server host-192-168-246-144:9093 --describe --group rdkafka_consumer_example --command-config ./config/c1)
    ent-ss1.properties
    [2023-03-03 17:46:36,073] WARN The configuration 'ssl.keystore.type' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
    [2023-03-03 17:46:36,074]
    [2023-03-03 17:46:36,074][2023-03-03 17:46:36,074][2023-03-03 17:46:36,074][2023-03-03 17:46:36,074]
    WARN The configuration 'ssl.truststore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)WARN The configuration 'ssl.keystore.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)MARN The configuration 'ssl.enabled.protocols' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)WARN The configuration 'ssl.key.password' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)] WARN The configuration 'ssl.keystore.location' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)[2023-03-03 17:46:36,874] MARN The configuration 'ssl.truststore.password" was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)[2023-03-03 17:46:36,074] WARN The configuration 'ssl.truststore.type' was supplied but isn't a known config.(org.apache.kafka.clients.admin.AdminClientConfig)
    [2023-03-03 17:46:36,074] MARN The configuration 'ssl.endpoint.identification.algorithm' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
    Consumer group 'rdkafka_consumer_example' has no active members.
    GROUP                    TOPIC         PARTITION   CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
    rdkafka_consumer_example topic_lanxin  0           44900          45995          1095  -          -       -
    rdkafka_consumer_example test_wmy      0           359367         359387         0     -          -       -
    

    有问题的是第一个“topic_lanxin”。
    demo和代码都尝试过换成不同的group.id去消费,只能维持一会儿正常,过会儿还是会REQTMOUT

    1年前
  • 半兽人 回复 wincentlibrdkafka消费一段时间后报错REQTMOUT...Timed out FetchRequest in flight 中 :

    解决了吗?显示某个消费组的消费详情你看了么

    1年前
  • wincent 回复 半兽人librdkafka消费一段时间后报错REQTMOUT...Timed out FetchRequest in flight 中 :

    有尝试过使用不同的group.id,但是结果也是一段时间后不定时REQTMOUT

    1年前
  • 订阅了 kafka 主题! · 1年前