Package com.simplicite.util.tools
Class KafkaTool
- java.lang.Object
-
- com.simplicite.util.tools.KafkaTool
-
- All Implemented Interfaces:
java.io.Serializable
public class KafkaTool extends java.lang.Object implements java.io.Serializable
Apache Kafka toolbox. EXPERIMENTAL- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.Integer
MAX_POLL_RECORDS
Max poll recordsstatic java.lang.String
OFFSET_RESET_EARLIEST
Offset reset earlieststatic java.lang.String
OFFSET_RESET_LATEST
Offset reset latest
-
Constructor Summary
Constructors Constructor Description KafkaTool(java.lang.String host, int port, java.lang.String clientId)
Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
closeConsumer(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer)
Close consumervoid
closeProducer(org.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String> producer)
Close producerorg.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String>
createConsumer(java.lang.String groupId)
Create consumerorg.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String>
createProducer(int nbRetries)
Create producerjava.util.Map<java.lang.Long,java.lang.String>
poll(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer, long wait)
Poll consumervoid
send(org.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String> producer, java.lang.String topic, java.lang.String value)
Sendvoid
subscribe(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer, java.lang.String topic)
subscribe
-
-
-
Field Detail
-
MAX_POLL_RECORDS
public static final java.lang.Integer MAX_POLL_RECORDS
Max poll records
-
OFFSET_RESET_LATEST
public static final java.lang.String OFFSET_RESET_LATEST
Offset reset latest- See Also:
- Constant Field Values
-
OFFSET_RESET_EARLIEST
public static final java.lang.String OFFSET_RESET_EARLIEST
Offset reset earliest- See Also:
- Constant Field Values
-
-
Method Detail
-
createProducer
public org.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String> createProducer(int nbRetries)
Create producer- Parameters:
nbRetries
- Number of retries- Returns:
- Producer
-
closeProducer
public void closeProducer(org.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String> producer)
Close producer- Parameters:
producer
- Producer
-
send
public void send(org.apache.kafka.clients.producer.Producer<java.lang.Long,java.lang.String> producer, java.lang.String topic, java.lang.String value)
Send- Parameters:
producer
- Producertopic
- Topicvalue
- Value
-
createConsumer
public org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> createConsumer(java.lang.String groupId)
Create consumer- Parameters:
groupId
- Group ID- Returns:
- Consumer
-
closeConsumer
public void closeConsumer(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer)
Close consumer- Parameters:
consumer
- Consumer
-
subscribe
public void subscribe(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer, java.lang.String topic)
subscribe- Parameters:
consumer
- Consumertopic
- Topic
-
poll
public java.util.Map<java.lang.Long,java.lang.String> poll(org.apache.kafka.clients.consumer.Consumer<java.lang.Long,java.lang.String> consumer, long wait)
Poll consumer- Parameters:
consumer
- Consumerwait
- Wait time in milliseconds- Returns:
- Records
-
-