20 Commits

Author	SHA1	Message	Date
Stan Campbell	c83dcd31f4	Add bulletproofing to better protect during allocation/init/free. ... JIRA: PART-3886	2014-08-19 13:48:24 -07:00
Stan Campbell	80754f6296	Remove bogus binaries from commit.	2014-07-22 11:37:41 -07:00
Stan Campbell	9c04fb1bc1	Add call to rb_thread_blocking_region to release the Ruby GVM lock and allow other threads to execute while we await IO from Kafka.	2014-06-20 10:52:50 -07:00
Stan Campbell	d9c2a93ec8	Add partition and brokers list configuration to the constructors for both Consumer and Producer.	2014-06-16 11:12:44 -07:00
Stan Campbell	aed11dcfac	Update documentation and gem version readying for release.	2014-06-13 10:47:34 -07:00
Stan Campbell	bcccda15a3	Removing more printf's. Removed the UUID to reduce dependencies.	2014-06-06 13:29:38 -07:00
Stan Campbell	874f02e673	Removed some extraneous logging. A little code cleanup.	2014-06-06 12:25:03 -07:00
Stan Campbell	6f0779d1b7	Update producer to use higher performance (don't wait so long in rd_kafka_poll).	2014-06-05 16:22:55 -07:00
Stan Campbell	d7c6387d21	Change the consumer code to use the batched callback method rather than blocking and timing out on single messages.	2014-06-05 16:03:09 -07:00
Stan Campbell	691d591d8c	Code cleanup, added a UUID to the configuration per instance for debugging.	2014-06-05 15:33:08 -07:00
Stan Campbell	a7a35deda9	All state now in configuration associated with instance. However, signal callbacks for trapping exit don't have the proper signature	2014-06-05 09:28:01 -07:00
Stan Campbell	841e33ecb9	Moving rk (instance pointer for the RdKafka producer, consumer, etc.) into per instance config.	2014-06-05 09:11:53 -07:00
Stan Campbell	66c7cbdbea	Added Producer configuration to struct. Simplified prodcfg and conscfg to common.	2014-06-05 09:03:00 -07:00
Stan Campbell	9a9d377863	Continuing edits to move state into the config structs to be held by instances of Producer and Consumer.	2014-06-04 09:26:01 -07:00
Stan Campbell	00409a4dcd	Initial, working refactor of Consumer to use Consumer configuration.	2014-06-03 16:49:37 -07:00
Stan Campbell	dea6483f0d	Initial creation of the Consumer configuration struct and management under Ruby.	2014-06-03 15:56:55 -07:00
Stan Campbell	b4e627d80b	Implement the stateless version of Producer.push	2014-06-02 12:52:20 -07:00
Stan Campbell	26be9f448f	Add in Producer behavior.	2014-06-02 12:47:25 -07:00
Stan Campbell	a497f9e911	Enabling the Consumer to yield results from Consumer.consume if provided with a block.	2014-05-30 18:50:24 -07:00
Stan Campbell	937eaea8fc	Initial files commit. Consumer working from Hermann::Consumer.	2014-05-30 12:58:38 -07:00