Kafka

Definitions

The providerId argument, including the default value "default", must correspond to an equivalent property in events.providers.kafka entry of the router config.yml.

@edfs_kafkaPublish

directive @edfs__kafkaPublish(topic: String!, providerId: String! = "default") on FIELD_DEFINITION

type edfs__PublishResult {
    success: Boolean!
}
Argument nameTypeValue

subject

String!

The event topic.

providerId

String!

The provider ID, which identifies the connection in the router config.yaml. If unsupplied, the provider ID "default" will be used.

@edfs__kafkaSubscribe

directive @edfs__kafkaSubscribe(topics: [String!]!, providerId: String! = "default") on FIELD_DEFINITION
Argument nameTypeValue

subjects

[String!]!

The event topics (it is possible to subscribe to multiple topics).

providerId

String!

The provider ID, which identifies the connection in the router config.yaml. If unsupplied, the provider ID "default" will be used.

For a full example please refer to:

pageKafka

Last updated