[jira] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

pull request at: https://github.com/apache/kafka/pull/1246 > KTable.count(final KeyValueMapper selector, String name) throw NPE > > > Key: KAFKA-3589 > URL: https://iss

[jira] [Resolved] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

/1246] > KTable.count(final KeyValueMapper selector, String name) throw NPE > > > Key: KAFKA-3589 > URL: https://issues.apache.org/jira/browse/KAFKA-3589 >

[jira] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15251533#comment-15251533 ] Damian Guy commented on KAFKA-3589: --- LGTM > KTable.count(final KeyValueMapper s

[jira] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

thor: Guozhang Wang Date: 2016-04-20T22:00:19Z v1 > KTable.count(final KeyValueMapper selector, String name) throw NPE > > > Key: KAFKA-3589 > URL: https://iss

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3589: - Labels: architecture (was: ) > KTable.count(final KeyValueMapper selector, String name) th

[jira] [Updated] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3589: - Fix Version/s: 0.10.0.0 > KTable.count(final KeyValueMapper selector, String name) throw

[jira] [Created] (KAFKA-3589) KTable.count(final KeyValueMapper selector, String name) throw NPE

Damian Guy created KAFKA-3589: - Summary: KTable.count(final KeyValueMapper selector, String name) throw NPE Key: KAFKA-3589 URL: https://issues.apache.org/jira/browse/KAFKA-3589 Project: Kafka

Re: KTable.count(...)

Hi Damain, The semantics of Count() is still depending on the KTable, where the records are of changelogs based on key. So for your example the KTable is really conceptually from an updating "source table" with only one record but with updating values from 1 to 5. And KTable.cou

Re: KTable.count(...)

iquan > > On Sun, Apr 17, 2016 at 9:59 AM, Damian Guy wrote: > > > Hi, > > > > I'm slightly confused by KTable.count(..). The javadoc says: > > > > Count number of records of this stream by the selected key into a new > > instance of {@link KTabl

Re: KTable.count(...)

> I'm slightly confused by KTable.count(..). The javadoc says: > > Count number of records of this stream by the selected key into a new > instance of {@link KTable}. > > So.. if i send 5 records with the same key to the input topic, as per below > > final KafkaProd

KTable.count(...)

Hi, I'm slightly confused by KTable.count(..). The javadoc says: Count number of records of this stream by the selected key into a new instance of {@link KTable}. So.. if i send 5 records with the same key to the input topic, as per below final KafkaProducer producer = new KafkaPro

[GitHub] kafka pull request: MINOR: KTable.count() to only take a selector ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/872 --- 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 enabl

[GitHub] kafka pull request: MINOR: KTable.count() to only take a selector ...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/872 MINOR: KTable.count() to only take a selector for key You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KCount