This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • avro

Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Migration of unmigrated content due to installation of a new plugin

...

Note: By default consumer parameters are wrapped into array. If you've got only one parameter, since 2.12 you can use singleParameter URI option to receive it direcly in the "in" message body without array wrapping.

Avro RPC URI Options

Wiki Markup
{div:class=confluenceTableSmall}
|| Name || Version || Description ||
| {{protocolClassName}} | | The class name of the avro protocol. |
| {{singleParameter}} | 2.12 | If true, consumer parameter won't be wrapped into array. Will fail if protocol specifies more then 1 parameter for the message |
| {{protocol}} | | Avro procol object. Can be used instead of {{protocolClassName}} when complex protocol needs to be created. One cane used #name notation to refer beans from the Registry |
| {{reflectionProtocol}} | 2.12 | If protocol object provided is reflection protocol. Should be used only with {{protocol}} parameter because for {{protocolClassName}} protocol type will be autodetected |
{div}

Avro RPC Headers

{div:class=confluenceTableSmall} || Name || Description || | {{CamelAvroMessageName}} | The name of the message to send. In consumer overrides message name from URI (if any)| {div}
Wiki Markup
Div
classconfluenceTableSmall

Name

Version

Description

protocolClassName

 

The class name of the avro protocol.

singleParameter

2.12

If true, consumer parameter won't be wrapped into array. Will fail if protocol specifies more then 1 parameter for the message

protocol

 

Avro procol object. Can be used instead of protocolClassName when complex protocol needs to be created. One cane used #name notation to refer beans from the Registry

reflectionProtocol

2.12

If protocol object provided is reflection protocol. Should be used only with protocol parameter because for protocolClassName protocol type will be autodetected

Avro RPC Headers

Div
classconfluenceTableSmall

Name

Description

CamelAvroMessageName

The name of the message to send. In consumer overrides message name from URI (if any)

Examples

An example of using camel avro producers via http:

...