Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[BUG] ilogtail 插件 input service_kafka报错 #471

Closed
codingdancer opened this issue Oct 17, 2022 Discussed in #459 · 1 comment
Closed

[BUG] ilogtail 插件 input service_kafka报错 #471

codingdancer opened this issue Oct 17, 2022 Discussed in #459 · 1 comment
Assignees
Labels
bug Something isn't working

Comments

@codingdancer
Copy link
Contributor

codingdancer commented Oct 17, 2022

Discussed in #459

Originally posted by codingdancer October 13, 2022
docker环境下 采集kakfa 数据 ,发现如下问题:
1.topic 配置问题
应该使用key 为Topics 配置,否则会报找不到topic
2.sarama-cluster 消费问题
具体报错信息

D:\software\dockerdesktop\ilogtail\1.1.1>docker logs docker_ilogtail
ilogtail started. pid: 12
register fun v2 0x697dd0 0x699a90 0x699490 0x699ac0
2022/10/13 03:20:43 DEBUG Now using Go's stdlib log package (via loggers/mappers/stdlib).
load log config /usr/local/ilogtail/plugin_logger.xml
panic: non-positive interval for NewTicker

goroutine 210 [running]:
time.NewTicker(0x0, 0x7f5427a69438)
        /go/src/time/tick.go:24 +0x151
github.com/bsm/sarama-cluster.(*Consumer).cmLoop(0xc0002b42d0, 0xc00066f4a0)
        /src/vendor/github.com/bsm/sarama-cluster/consumer.go:452 +0x5c
github.com/bsm/sarama-cluster.(*loopTomb).Go.func1(0xc000145360, 0xc00021af70)
        /src/vendor/github.com/bsm/sarama-cluster/util.go:73 +0x7d
created by github.com/bsm/sarama-cluster.(*loopTomb).Go
        /src/vendor/github.com/bsm/sarama-cluster/util.go:69 +0x68
ilogtail exited unexpectedly

docker 配置如下:

enable: true
inputs:
  - Type: service_kafka
    Version: 2.1.1
    Brokers: 
      - 10.71.48.62:9092
    ConsumerGroup: skyeyeResult
    Topics:
      - test
    ClientID: ilogtail
flushers:   
  - Type: flusher_kafka
    Brokers: 
      - 10.71.48.62:9092
    Topic: bmw_bms_collector_rsk

解决方式 : 替换consumer.go 452行代码

	ticker := time.NewTicker(c.client.config.Consumer.Offsets.AutoCommit.Interval)
@yyuuttaaoo
Copy link
Collaborator

你好,文档确实是错了,代码也可以和文档的fix一起提交PR上来。

@yyuuttaaoo yyuuttaaoo changed the title logtail 插件 input service_kafka报错 [bug] ilogtail 插件 input service_kafka报错 Oct 18, 2022
@yyuuttaaoo yyuuttaaoo added the bug Something isn't working label Oct 18, 2022
@yyuuttaaoo yyuuttaaoo changed the title [bug] ilogtail 插件 input service_kafka报错 [BUG] ilogtail 插件 input service_kafka报错 Oct 18, 2022
@yyuuttaaoo yyuuttaaoo added this to the v1.3 milestone Nov 8, 2022
@yyuuttaaoo yyuuttaaoo modified the milestones: v1.3, v1.4 Dec 8, 2022
@yyuuttaaoo yyuuttaaoo modified the milestones: v1.4, v1.5 Mar 21, 2023
@yyuuttaaoo yyuuttaaoo modified the milestones: v1.5, v1.6 May 1, 2023
@yyuuttaaoo yyuuttaaoo modified the milestones: v1.6, v1.7 Jun 8, 2023
@yyuuttaaoo yyuuttaaoo removed this from the v1.7 milestone Jul 2, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

3 participants