Displaying 1 to 10 from 10 results

kafka-cpp - CPP client for Apache Kafka

  •    C++

This library allows you to produce messages to the Kafka distributed publish/subscribe messaging service.Run this to generate the makefile for your system. Do this first.

libkafka - A C++ client library for Apache Kafka v0.8+. Also includes C API.

  •    C++

/////////////////////////////////////////////////////////////////////////// // // libkafka - C/C++ client for Apache Kafka v0.8+ // // David Tompkins -- 8/8/2013 // tompkins@adobe_dot_com // /////////////////////////////////////////////////////////////////////////// // // Copyright (c) 2013 Adobe Systems Incorporated. All rights reserved. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. // ///////////////////////////////////////////////////////////////////////////

csi-kafka - C++11 producer/consumer library for Apache Kafka v0

  •    C++

C++11 producer/consumer library for Apache Kafka v0.10.1.0+. Does not require zookeeper integration




libkafka-asio - C++ Kafka Client Library using Boost Asio

  •    C++

It supports GZIP and Snappy message compression and therefore relies on the zlib and Snappy libraries. Message compression can optionally be turned off.The library was tested on Linux (GCC 4.9, clang 3.5.1) and Windows (MSVC 10, 11, 12). There is a set of unit tests available under test.

dory - Producer daemon for Apache Kafka

  •    C++

Dory decouples message sources from the Kafka cluster. A client is not forced to wait for an ACK after sending a message, since Dory handles the details of waiting for ACKs from Kafka and resending messages when necessary. Likewise, a client is not burdened with holding onto messages until it has a reasonable-sized batch to send to Kafka. If a client crashes immediately after sending a message to Dory, the message is safe with Dory. However, if the client assumes responsibility for interacting with Kafka, a crash will cause the loss of all batched messages, and possibly sent messages for which an ACK is pending.Dory provides uniformity of mechanism for status monitoring and data quality reporting through its web interface. Likewise, it provides a unified configuration mechanism for settings related to batching, compression, and other aspects of interaction with Kafka. This simplifies system administration, as compared to a multitude of producer mechanisms for various programming languages and applications, each with its own status monitoring, data quality reporting, and configuration mechanisms or lack thereof.

cppkafka - Modern C++ Apache Kafka client library (wrapper for librdkafka)

  •    C++

cppkafka allows C++ applications to consume and produce messages using the Apache Kafka protocol. The library is built on top of librdkafka, and provides a high level API that uses modern C++ features to make it easier to write code while keeping the wrapper's performance overhead to a minimum. cppkafka is a high level C++ wrapper for rdkafka, aiming to allow using rdkafka in a simple, less error prone way.


kafkabridge - The Apache Kafka Client SDK

  •    C++

Navigate to the cxx/c installation directory,and run build.sh -release, you will get a new file named libqbus.so in the "./lib/release" directory. Navigate to the Go installation directory,and run build.sh, you will get the new files qbus.go and libQBus_go.so in the directory "gopath/src/qbus".





We have large collection of open source products. Follow the tags from Tag Cloud >>


Open source products are scattered around the web. Please provide information about the open source projects you own / you use. Add Projects.