Event Framework
R24 AMR | Min(s) read

Posting Inflow Request to Topics

This section explains how to enable Inflow to accept requests from Azure Eventhub and Kafka topics.

Enabling Requests through Topics

By default, accepting Inflow request through topics such as Eventhub and Kafka are turned off in Inflow.

To support Eventhub or Kafka, you must go to Inflow_EE.ear > APP-INF > lib > Inflow-Service-(version) > applicationContext.xml and then change the value of enableInflowStream property to true or false as shown below. Setting the value to true and false enables and disables the Inflow Stream, respectively.

<bean id="enableInflowStream" class="java.lang.Boolean">
   <constructor-arg value="true"/>
</bean>

Configuring Properties

To configure the InflowStream properties, go to Inflow_EE.ear > Inflow_STREAM.war > WEB-INF > classes > application-eventhub.properties and configure the properties. The following properties are common to both Kafka and Eventhub.

For Eventhub, the prefix of the properties should be inflow.kafka.

Property

Description

Default Value

inflow.kafka.stream.bootstrap.servers

Bootstrap servers

No default value

inflow.kafka.stream.consumer.kafka.topicName

Topic where the events must be fetched from

No default value

inflow.kafka.stream.consumer.kafka.groupidConfig

Consumer group id

No default value

inflow.kafka.stream.consumer.kafka.clientidConfig

Consumer client it

No default value

inflow.kafka.stream.max.poll.records

Consumer max poll records

100

 

inflow.kafka.stream.consumer.kafka.timeout.config

Consumer Timeout

1000

inflow.kafka.stream.auto.offset.reset

Stream offset

earliest

inflow.kafka.stream.max.poll.interval.ms

Consumer max poll interval in ms

7000

inflow.kafka.stream.consumer.timeout.millis

Consumer timeout in milliseconds

1000

inflow.kafka.stream.session.timeout.ms

Stream session timeout in milliseconds

6000

The following are specific to Eventhub and mandatory properties.

Property

Description

Default Value

inflow.kafka.stream.security.protocol

Security protocol

SASL_SSL

inflow.kafka.stream.sasl.mechanism

 

Stream sasl mechanism

PLAIN

inflow.kafka.stream.sasl.jaas.config

 

Stream sasl jaas config

No default value

Environmental Variables

You can configure the properties given in the Configuring Properties section through system or environmental properties. If environmental or system properties are specified in the environment in which Inflow is deployed, then these properties are given higher preference and the properties in application-eventhub.properties are skipped.

Mandatory Properties

You must provide all the following mandatory properties. The following properties are common to all event streams (Kafka, Kinesis and Eventhub).

  • inflow.kafka.stream.consumer.kafka.clientidConfig

  • inflow.kafka.stream.consumer.kafka.groupidConfig

  • inflow.kafka.stream.consumer.kafka.timeout.config

  • inflow.kafka.stream.bootstrap.servers

However, it is recommended to configure all the properties provided in the Configuring Properties section.

Inflow Stream Deployment

Inflow Stream is packaged along with Inflow_EE.ear and the deployment happens along with the package. After deployment, Inflow Stream starts fetching events or requests from the configured Inflow Eventhub or topic and then processes the events.

Copyright © 2020- Temenos Headquarters SA

Published on :
Monday, May 27, 2024 4:29:34 PM IST