The documentation you are viewing is for Dapr v1.8 which is an older version of Dapr. For up-to-date documentation, see the latest version.
Apache Kafka
关于Apache Kafka pubsub组件的详细文档
配置
要设置Apache Kafka pubsub,请创建一个pubsub.kafka
类型的组件。 See this guide on how to create and apply a pubsub configuration.
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: kafka-pubsub
namespace: default
spec:
type: pubsub.kafka
version: v1
metadata:
# Kafka broker connection setting
- name: brokers
value: "dapr-kafka.myapp.svc.cluster.local:9092"
- name: authRequired
value: "true"
- name: saslUsername
value: "adminuser"
- name: saslPassword
value: "KeFg23!"
- name: maxMessageBytes
value: 1024
Warning
以上示例将密钥明文存储, It is recommended to use a secret store for the secrets as described here.元数据字段规范
字段 | 必填 | 详情 | Example |
---|---|---|---|
brokers | Y | 逗号分隔的kafka broker列表 | localhost:9092 , dapr-kafka.myapp.svc.cluster.local:9092 |
authRequired | N | 在Kafka broker上启用验证。 默认值为 "false" . |
"true" , "false" |
saslUsername | N | 用于认证的用户名。 只有当 authRequired 设置为 true 时才需要。 | "adminuser" |
saslPassword | N | 用于认证的密码。 可以用secretKeyRef 来引用密钥。 只有当 authRequired 设置为 true 时才需要。 Can be secretKeyRef to use a secret reference |
"" , "KeFg23!" |
maxMessageBytes | N | 单条Kafka消息允许的最大消息大小。 默认值为 1024。 | 2048 |
每次调用的元数据字段
分区键
当调用Kafka 发布/订阅时,可以通过在请求url中使用metadata
查询参数来提供一个可选的分区键。
参数名是partitionKey
。
You can run Kafka locally using this Docker image. To run without Docker, see the getting started guide here.
curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.partitionKey=key1 \
-H "Content-Type: application/json" \
-d '{
"data": {
"message": "Hi"
}
}'
创建 Kafka 实例
To run Kafka on Kubernetes, you can use any Kafka operator, such as Strimzi.
相关链接
- Dapr组件的基本格式
- Read this guide for instructions on configuring pub/sub components
- 发布/订阅构建块
Feedback
Was this page helpful?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.