Package | Description |
---|---|
io.toro.martini |
Modifier and Type | Method and Description |
---|---|
static KafkaClientsMethods.SerializerClass |
KafkaClientsMethods.SerializerClass.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KafkaClientsMethods.SerializerClass[] |
KafkaClientsMethods.SerializerClass.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.clients.producer.KafkaProducer |
KafkaClientsMethods.createProducer(String bootstrapServers,
KafkaClientsMethods.SerializerClass keySerializer,
KafkaClientsMethods.SerializerClass valueSerializer)
Creates a
producer for publishing messages. |
static org.apache.kafka.clients.producer.KafkaProducer |
KafkaClientsMethods.createProducer(String bootstrapServers,
KafkaClientsMethods.SerializerClass keySerializer,
KafkaClientsMethods.SerializerClass valueSerializer,
Properties producerConfigs)
Create a
producer using the provided configuration ,
for publishing messages. |
Copyright © 2021. All rights reserved.