守护轻鸟

0 声望

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

个人动态
  • 冷暖自知 回复 守护轻鸟 在 kafka新建topic无法使用新的group消费 中 ：

    想问下，问题解决了么，我也遇到了同样的问题

    5年前
  • 发表了 kafka V2.1.1 poll 方法过时  
    5年前
  • 发表了 kafka connect 转换异常  
    5年前
  • 守护轻鸟 在 kafka connect 启动后，报错：Task is being killed and will not recover until manually restarted？ 发表评论：

    请问这个问题解决了吗？ 我也遇到了这个问题

    5年前
  • 半兽人 回复 守护轻鸟 在 kafka自带connect 和 confluent platform connect 区别 中 ：

    过滤（正则），logstash 和 filebeat 都可以的。
    logstash的我整理的太少了
    https://www.orchome.com/471

    5年前
  • 守护轻鸟 回复 半兽人 在 kafka自带connect 和 confluent platform connect 区别 中 ：

    我的业务场景是接收kafka消息，然后做一些数据清洗，最后存到es中。logstash 和 filebeat 是用来发送消息到kafka吧？

    5年前
  • 发表了 kafka自带connect 和 confluent platform connect 区别  
    5年前
  • 发表了 如何计算一条kafka消息大小?  
    6年前
  • 发表了 kakfa客户端异常  
    6年前
  • 订阅了 kafka 主题！ · 7年前
  • 订阅了 java 主题！ · 7年前
  • 守护轻鸟 回复 半兽人 在 kafka新建topic无法使用新的group消费 中 ： 
    root@qdjcroot@qdjc-zbjg3:/usr/local/kafka_2.12-0.11.0.1# bin/kafka-consumer-groups.sh --new-consumer --bootstrapkafka# bin/kafka-consumer# bin/kafka-consumer# bin/kafka-consumer-groups.sh --new# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server# bin/kafka-consumer-groups# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-serverkafka# bin/kafka-consumer-groups.sh --new-consumer# bin/kafka-consumer-groups.sh --new-consumer# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server# bin/kafka# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new-consumer# bin/kafka-consumer-groups# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new-consumer --bootstrapbin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server# bin/kafka# bin/kafka-consumer-groups.sh --new-consumer# bin/kafka-consumer-groups.sh --new-consumer --bootstrap# bin/kafka-consumer-groups.sh --new-consumerin/kafka# bin/kafka-consumer-groups.sh --new-consumer --bootstrap# bin-consumer-groups.sh --new-consumer# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups.sh --new# bin/kafka-consumer-groups.sh# bin/kafka-consumer-groups# bin/kafka-consumer-groups.sh --new-consumer --bootstrap# bin/kafka-consumer-groups# bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.16.37.70:9092 --describe --group ctsv-compress-group-id
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).

Error: Executing consumer group command failed due to The consumer group command timed out while waiting for group to initialize: 
root@qdjc-zbjg3:/usr/local/kafka_2.12-0.11.0.1# bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group ctsv-comress-group-id
Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).

Error: The consumer group 'ctsv-comress-group-id' does not exist.
    7年前
  • 订阅了 history 主题！ · 7年前