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.
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.
In this topic