Crystal-lang wrapper for the librdkafka C-library Apache Kafka client. Contributions welcome.

STATUS:

• Simple polling producer works for keys,values that are strings.
• Simple polling consumer works for keys,values that are strings.

Add this to your application's shard.yml:

dependencies:
  kafka:
    github: packetzero/kafka.cr

require "kafka"

See examples in kafka_examples