class Kafka::Topic

• Kafka::Topic
• Reference
• Object

Defined in:

kafka/topic.cr

Constructors

• .new(rk : Consumer | Producer, topic : String, conf : TopicConfiguration)

  Creates a new topic handle for topic named topic.

Instance Method Summary

• #consume(partition : Int32, timeout_ms = 1000) : Message | Nil

  Consume a single message from partition.

• #consume_batch(partition : Int32, timeout_ms = 1000, rkmessages_size = 64) : Array(Message)

  Consume up to rkmessages_size from partition putting a pointer to each message in the application provided array rkmessages (of size rkmessages_size entries).

• #consume_callback(partition : Int32, timeout_ms = 1000, &consume_cb : Message -> )

  Consumes messages from partition, calling the provided callback for each consumed messsage.

• #consume_start(partition : Int32, offset : Int64, rkqu : Queue)

  Start consuming messages for partition at offset, but re-routes incoming messages to the provided queue rkqu.

• #consume_start(partition : Int32, offset : Int64)

  Start consuming messages for partition at offset.

• #consume_stop(partition : Int32)

  Stop consuming messages for partition, purging all messages currently in the local queue.

• #produce(partition : Int32, payload : String, key : String = nil, msg_opaque = nil)

  Produce and send a single message to broker.

• #produce_batch(partition : Int32)

  Produce multiple messages.

• #to_unsafe : LibKafka::RdKafkaTopicT

Constructor Detail

Instance Method Detail