[jira] [Updated] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

[ https://issues.apache.org/jira/browse/KAFKA-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] The Data Lorax updated KAFKA-2901: -- Description: The {{ListGroupsRequest}} and {{DescribeGroupsRequest}} added to 0.9.0.0 allow

[jira] [Commented] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

[ https://issues.apache.org/jira/browse/KAFKA-2901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030059#comment-15030059 ] Ben Stopford commented on KAFKA-2901: - Thanks andy. Just looping in [~hachikuji] > Extend ListGroups

[jira] [Commented] (KAFKA-2891) Gaps in messages delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030082#comment-15030082 ] Ben Stopford commented on KAFKA-2891: - One more bit of info - when this problem occurs the missing

Possible StreamingConfig Bug

All, When starting KafkaStreaming I'm getting the following error (even when explicitly setting the groupId with props.put("group.id","test-consumer-group") ); Exception in thread "StreamThread-1" org.apache.kafka.common.KafkaException: org.apache.kafka.common.errors.ApiException: The configured

[jira] [Created] (KAFKA-2901) Extend ListGroups and DescribeGroup APIs to cover offsets

The Data Lorax created KAFKA-2901: - Summary: Extend ListGroups and DescribeGroup APIs to cover offsets Key: KAFKA-2901 URL: https://issues.apache.org/jira/browse/KAFKA-2901 Project: Kafka

[jira] [Commented] (KAFKA-2891) Gaps in messages delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030337#comment-15030337 ] Jason Gustafson commented on KAFKA-2891: [~benstopford] To be clear, are you saying that the

[GitHub] kafka pull request: Avoiding warning about generics in sample code

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/594 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

[ https://issues.apache.org/jira/browse/KAFKA-2903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-2903: --- Affects Version/s: 0.9.0.0 0.8.2.1 Fix Version/s: 0.9.0.0 > FileMessageSet's

Re: Possible StreamingConfig Bug

The group id is removed from the restore consumer config because the restore consumer should not participate in the specified consumer group. I don't know why it is failing. On Fri, Nov 27, 2015 at 12:37 PM, Guozhang Wang wrote: > Hello Bill, > > Thanks for reporting it,

[GitHub] kafka pull request: KAFKA-2899: (trivial) Log unexpected exception...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/593 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (KAFKA-2899) Should log unexpected exceptions thrown when reading from local log

[ https://issues.apache.org/jira/browse/KAFKA-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2899. -- Resolution: Fixed Fix Version/s: 0.9.0.1 Issue resolved by pull request 593

[GitHub] kafka pull request: MINOR: fix verifiable consumer assertion

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/597 MINOR: fix verifiable consumer assertion You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka fix-verifiable-consumer-assertion

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

[ https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-2902: --- Description: When starting a KafkaStreaming instance the StreamingConfig.getConsumerConfigs method

[jira] [Created] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

Bill Bejeck created KAFKA-2902: -- Summary: StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs Key: KAFKA-2902 URL: https://issues.apache.org/jira/browse/KAFKA-2902

Build failed in Jenkins: kafka-trunk-jdk7 #861

See Changes: [wangguoz] KAFKA-2899: improve logging when unexpected exceptions thrown in reading [wangguoz] MINOR: Avoiding warning about generics in sample code -- [...truncated 1371

[jira] [Updated] (KAFKA-2899) Should log unexpected exceptions thrown when reading from local log

[ https://issues.apache.org/jira/browse/KAFKA-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2899: - Assignee: Ben Stopford > Should log unexpected exceptions thrown when reading from local log >

[jira] [Commented] (KAFKA-2899) Should log unexpected exceptions thrown when reading from local log

[ https://issues.apache.org/jira/browse/KAFKA-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15030210#comment-15030210 ] ASF GitHub Bot commented on KAFKA-2899: --- Github user asfgit closed the pull request at:

Re: Possible StreamingConfig Bug

Hello Bill, Thanks for reporting it, this is a valid issue, could you create a ticket? Guozhang On Fri, Nov 27, 2015 at 6:19 AM, Bill Bejeck wrote: > All, > > When starting KafkaStreaming I'm getting the following error (even when > explicitly setting the groupId with

[jira] [Created] (KAFKA-2903) FileMessageSet's read method maybe has problem when start is not zero

Pengwei created KAFKA-2903: -- Summary: FileMessageSet's read method maybe has problem when start is not zero Key: KAFKA-2903 URL: https://issues.apache.org/jira/browse/KAFKA-2903 Project: Kafka

Build failed in Jenkins: kafka_0.9.0_jdk7 #47

See Changes: [wangguoz] KAFKA-2899: improve logging when unexpected exceptions thrown in reading [wangguoz] MINOR: Avoiding warning about generics in sample code -- Started by an SCM change

Build failed in Jenkins: kafka-trunk-jdk8 #190

See Changes: [wangguoz] KAFKA-2899: improve logging when unexpected exceptions thrown in reading [wangguoz] MINOR: Avoiding warning about generics in sample code -- Started by an SCM change

[jira] [Work started] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

[ https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2902 started by Bill Bejeck. -- > StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of >

[jira] [Work stopped] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

[ https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2902 stopped by Bill Bejeck. -- > StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of >

[GitHub] kafka pull request: Kafka 2902 streaming config use get base consu...

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/596 Kafka 2902 streaming config use get base consumer configs You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka

Re: Possible StreamingConfig Bug

I think the problem is that "getConsumerConfigs" called in StreamThread. createConsumer() triggers getRestoreConsumerConfigs instead of getBaseConsumerConfigs, which seems a bug to me. Guozhang On Fri, Nov 27, 2015 at 8:01 PM, Yasuhiro Matsuda < yasuhiro.mats...@gmail.com> wrote: > The group id

[jira] [Updated] (KAFKA-2902) StreamingConfig getConsumerConfiigs uses getRestoreConsumerConfigs instead of getBaseConsumerConfigs

[ https://issues.apache.org/jira/browse/KAFKA-2902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-2902: --- Status: Patch Available (was: Open) Changes made for using getBaseConsumerProps from StreamingConfig

Re: group protocol/metadata documentation

Hey Dana, The intention of the UserData field is to allow custom partition assignments to leverage member-specific metadata. For example, it might include the rack name of the host for a rack-aware assignment strategy or the number of cpus for a resource-based assignment strategy. The strategies

Build failed in Jenkins: kafka-trunk-jdk8 #189

See Changes: [wangguoz] KAFKA-2882: Add constructor cache for Snappy and LZ4 Output/Input -- [...truncated 2793 lines...] kafka.log.CleanerTest > testCleanSegments PASSED kafka.log.CleanerTest

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

GitHub user ZoneMayor opened a pull request: https://github.com/apache/kafka/pull/595 KAFKA-2875: remove slf4j multi binding warnings when running form source distribution You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029592#comment-15029592 ] ASF GitHub Bot commented on KAFKA-2875: --- GitHub user ZoneMayor opened a pull request: