ConsumerHelper
Helper for handling Kafka Consumer
Attributes
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
-
ConsumerHelper.type
Members list
Value members
Concrete methods
Prepare the properties for the kafka consumer.
Prepare the properties for the kafka consumer.
The properties are taken from (whatever comes first):
- java properties in the command line (-Dauto.commit.interval.ms=...)
- the user properties passed to this function
- the parameters of this function
- default value (if exists)
Default properties (DefaultProps) are added if not already present in the user.properties
Value parameters
- groupId
-
the group.id of the consumer
- kafkaServers
-
the kafka servers to connect to
- keyDeserializer
-
the deserializer for the keys
- userProps
-
User defined properties
- valueDeserializer
-
the deserializer for the values
Attributes
- Returns
-
the properties to pass to the kafka Consumer
Prepare the properties for the kafka consumer for java.
Prepare the properties for the kafka consumer for java.
Delegates to setupProps.
Value parameters
- groupId
-
the group.id of the consumer
- kafkaServers
-
the kafka servers to connect to
- keyDeserializer
-
the deserializer for the keys
- userProps
-
User defined properties
- valueDeserializer
-
the deserializer for the values
Attributes
- Returns
-
the properties to pass to the kafka Consumer
Concrete fields
The default kafka broker
The default kafka broker
Attributes
The name of the default class to deserialize the value
The name of the default class to deserialize the value
Attributes
Default properties for the consumer
Default properties for the consumer
Attributes
The name of the default class to deserialize the value
The name of the default class to deserialize the value