-
Notifications
You must be signed in to change notification settings - Fork 9
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
Refactor: Using Kafka instead of RabbitMQ #33
base: main
Are you sure you want to change the base?
Conversation
Kafka的日志管理同样可以利用EsHook,而且可以区分正常的Logger与ErrLogger,我在想我们是否需要这个。 |
ok |
pkg/kafka/kafka.go
Outdated
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
包名我觉得可以改一下,换成mq?
感觉也可以合掉了 |
已经解决了conflicts |
KAFKA_CFG_ADVERTISED_LISTENERS=BROKER://fzuhelper-kafka:9092,EXTERNAL://127.0.0.1:9093 | ||
KAFKA_CFG_INTER_BROKER_LISTENER_NAME=BROKER | ||
[email protected]:9094 | ||
ALLOW_PLAINTEXT_LISTEN |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
这是什么?允许 PLAINTECT_LISTEN?
Using Kafka instead of RabbitMQ
Refs: #30