CREATE NOTIFIER

Creates a push-based notifier to send event notifications and messages out of Vertica.

Syntax

CREATE NOTIFIER notifier‑name ACTION action‑url MAXMEMORYSIZE max‑memory‑size
... [ [NO] CHECK COMMITTED ]
... [ ENABLE | DISABLE ]
... [ IDENTIFIED BY uuid ]
... [ MAXPAYLOAD max‑payload‑size ]
... [ PARAMETERS 'adapter‑params' ]
         

Parameters

notifier‑name This notifier's unique identifier.
ACTION action‑url

Identifies the target Kafka server, where action‑url has the following format:

kafka://kafka‑server‑ip‑address:port‑number

For example:

kafka://127.0.0.1:9092
MAXMEMORYSIZE

The maximum size of the internal notifier, up to 2 TB, specified in kilobytes, megabytes, gigabytes, or terabytes as follows:

MAXMEMORYSIZE integer{K|M|G|T}

If the queue exceeds this size, the notifier drops excess messages.

[NO] CHECK COMMITTED Specifies to wait for delivery confirmation before sending the next message in the queue. Not all messaging systems support delivery confirmation.
ENABLE|DISABLE Specifies whether to enable or disable the notifier. If you omit this parameter, Vertica sets this notifier to ENABLE.
IDENTIFIED BY uuid Specifies the notifier's unique identifier. If set, all the messages published by this notifier have this attribute.
MAXPAYLOAD

The maximum size of the message, up to 2 TB, specified in kilobytes, megabytes, gigabytes, or terabytes as follows:

MAXPAYLOAD integer{K|M|G|T}

The default setting is adapter-specific—for example, 1 M for Kafka.

PARAMETERS 
'adapter‑params'

Specifies one or more optional adapter parameters that are passed as a string to the adapter. Adapter parameters apply only to the adapter associated with the notifier.

For Kafka notifiers, refer to Configuring Kafka for Vertica.

Privileges

Database Administrator

Examples

Create a Kafka notifier:

=> CREATE NOTIFIER my_dc_notifier
	ACTION 'kafka://172.16.20.10:9092'
	MAXMEMORYSIZE '1G'
	IDENTIFIED BY 'f8b0278a-3282-4e1a-9c86-e0f3f042a971'
	NO CHECK COMMITTED;

Create a notifier with an adapter-specific parameter:

=> CREATE NOTIFIER my_notifier 
	ACTION 'kafka://127.0.0.1:9092' 
	MAXMEMORYSIZE '10M' 
	PARAMETERS 'queue.buffering.max.ms=1000'; 			

See Also