Skip to content

High level consumer with non-blocking feature #23

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
aNutForAJarOfTuna wants to merge 15 commits into
base: integration
Choose a base branch
from
Open

High level consumer with non-blocking feature #23

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
cff9307
#20 Fix memory leak
Jroland Aug 7, 2014
bdec3d1
Merge branch 'integration'
Jroland Sep 16, 2014
2c6ddb0
Merge branch 'integration'
Jroland Oct 30, 2014
9779f9f
add high level kafka consumer, integrate with zookeeper client to use…
Nov 11, 2014
ac99911
code refactoring.
Nov 11, 2014
971954e
add native high level consumer, which directly get consumer offset fr…
Nov 11, 2014
fb9dfd5
check offset for consumer group if it's in a correct range; if not, c…
Nov 13, 2014
acce752
refactoring
Nov 13, 2014
a4dc050
add unit tests for NativeHLConsumer partially.
Nov 17, 2014
367d01c
add unit tests for NativeHLConsumer
Nov 17, 2014
7a50810
some docs for NativeHLConsumer.
Nov 18, 2014
32822c1
non-blocking feature added and tests also.
Nov 18, 2014
b2d4389
allow consumer to specify max bytes for message in fetch request, ver…
Nov 25, 2014
292a36d
clean up nupkg and ignore
Nov 25, 2014
4a2745e
versioning
Nov 25, 2014
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
versioning
  • Loading branch information
Peng Zang committed Nov 25, 2014
commit 4a2745e48aa4d2927eeaede941a6ae94f1660ff4
2 changes: 1 addition & 1 deletion src/kafka-net.nuspec
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
<package xmlns="http://schemas.microsoft.com/packaging/2010/07/nuspec.xsd">
<metadata>
<id>kafka-net</id>
<version>1.0.0.0-alpha</version>
<version>@build.number@-alpha</version>
<authors>James Roland</authors>
<owners>James Roland</owners>
<licenseUrl>https://github.com/Jroland/kafka-net/blob/master/LICENSE</licenseUrl>
Expand Down
2 changes: 1 addition & 1 deletion src/kafka-net/Protocol/FetchRequest.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ public class Fetch
{
public Fetch()
{
MaxBytes = FetchRequest.DefaultMinBlockingByteBufferSize * 800;
MaxBytes = FetchRequest.DefaultMinBlockingByteBufferSize * 8;
}

/// <summary>
Expand Down
2 changes: 1 addition & 1 deletion src/kafka-net/kafka-net.nuspec
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
<package xmlns="http://schemas.microsoft.com/packaging/2010/07/nuspec.xsd">
<metadata>
<id>kafka-net</id>
<version>1.0.0.1-beta</version>
<version>$version$-beta</version>
<authors>James Roland</authors>
<owners>James Roland</owners>
<licenseUrl>https://github.com/Jroland/kafka-net/blob/master/LICENSE</licenseUrl>
Expand Down