Re: KStream: KTable-KTable leftJoin with key only on RHS of join generates null in joined table

Hello, The KTable join semantics is not exactly the same with that of a RDBMS. You can fine detailed semantics in the web docs (search for Joining Streams): http://docs.confluent.io/3.0.0/streams/developer-guide.html#kafka-streams-dsl In a nutshell, the joiner will be triggered only if both /

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

See Changes: [wangguoz] MINOR: Fix few documentation errors in streams quickstart -- [...truncated 3313 lines...] kafka.coordinator.GroupMetadataManagerTest > testStoreNonEmptyGroup PASSED

Build failed in Jenkins: kafka-0.10.0-jdk7 #141

See Changes: [wangguoz] resolve conflicts -- [...truncated 1706 lines...] kafka.log.LogManagerTest > testRecoveryDirectoryMappingWithRelativeDirectory PASSED kafka.log.LogManagerTest >

[jira] [Reopened] (KAFKA-3927) kafka broker config docs issue

[ https://issues.apache.org/jira/browse/KAFKA-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shawn Guo reopened KAFKA-3927: -- Thanks [~harsha_ch] but I think they does have a default value in broker. for example in my

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

See Changes: [wangguoz] MINOR: Fix few documentation errors in streams quickstart -- [...truncated 1909 lines...] kafka.api.SaslMultiMechanismConsumerTest > testSimpleConsumption PASSED

[GitHub] kafka pull request #1571: MINOR: Fix few documentation errors in streams qui...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1571 --- 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-3689) Exception when attempting to decrease connection count for address with no connections

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3689: --- Priority: Major (was: Minor) > Exception when attempting to decrease connection count for address

[jira] [Updated] (KAFKA-3689) Exception when attempting to decrease connection count for address with no connections

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3689: --- Summary: Exception when attempting to decrease connection count for address with no connections

Re: KStream: KTable-KTable leftJoin with key only on RHS of join generates null in joined table

Same happens for regular join, keys that appear only in one stream will make it to output KTable tC with a null for either input stream. I guess it's related to Kafka-3911 Enforce ktable Materialization or umbrella JIRA 3909, Queryable state for Kafka Streams? On Mon, Jul 4, 2016 at 8:45 PM,

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1694: --- Issue Type: New Feature (was: Bug) > KIP-4: Command line and centralized operations >

[jira] [Updated] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3704: --- Issue Type: Improvement (was: Bug) > Improve mechanism for compression stream block size selection

KStream: KTable-KTable leftJoin with key only on RHS of join generates null in joined table

If we have two streams A and B for which we associate tables tA and tB, then create a table tC as ta.leftJoin(tB, ) and then we have a key kB in stream B but never made it to tA nor tC, do we need to inject a pair (k,v) of (kB, null) into resulting change log for tC ? It sounds like it is

Build failed in Jenkins: kafka-0.10.0-jdk7 #140

See Changes: [me] KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) -- [...truncated 1668 lines...] kafka.log.LogSegmentTest > testReadFromGap PASSED

[jira] [Resolved] (KAFKA-3927) kafka broker config docs issue

[ https://issues.apache.org/jira/browse/KAFKA-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-3927. --- Resolution: Not A Bug > kafka broker config docs issue >

[jira] [Commented] (KAFKA-3927) kafka broker config docs issue

[ https://issues.apache.org/jira/browse/KAFKA-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361829#comment-15361829 ] Sriharsha Chintalapani commented on KAFKA-3927: --- [~guoxu1231] for

Re: [VOTE] KIP-60: Make Java client class loading more flexible

+1 (binding) Harsha On Mon, Jul 4, 2016 at 8:28 AM Ismael Juma wrote: > +1 (binding) > > Ismael > > On Fri, Jul 1, 2016 at 12:27 PM, Rajini Sivaram < > rajinisiva...@googlemail.com> wrote: > > > I would like to initiate the voting process for KIP-60 ( > > > > >

[jira] [Updated] (KAFKA-3854) Subsequent regex subscription calls fail

[ https://issues.apache.org/jira/browse/KAFKA-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3854: - Fix Version/s: 0.10.0.1 > Subsequent regex subscription calls fail >

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

See Changes: [me] KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) -- [...truncated 6679 lines...] kafka.message.ByteBufferMessageSetTest > testValidBytes PASSED

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

See Changes: [me] KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) -- [...truncated 3334 lines...] kafka.producer.AsyncProducerTest > testJavaProducer PASSED

[jira] [Commented] (KAFKA-3836) KStreamReduce and KTableReduce should not pass nulls to Deserializers

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

[GitHub] kafka pull request #1585: KAFKA-3836: KStreamReduce and KTableReduce should ...

GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1585 KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-3854) Subsequent regex subscription calls fail

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

[GitHub] kafka pull request #1572: KAFKA-3854: Fix issues with new consumer's subsequ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1572 --- 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-3854) Subsequent regex subscription calls fail

[ https://issues.apache.org/jira/browse/KAFKA-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3854: - Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved

[GitHub] kafka pull request #1584: MINOR: fix generics in KStream.groupBy(...)

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1584 MINOR: fix generics in KStream.groupBy(...) The `KStream.groupBy(..)` calls don't change the value, only the key, so they don't need the type param `V1` as the new stream will always be of type

[GitHub] kafka pull request #1583: MINOR: fix generics in KStream.groupBy(...)

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

Re: [VOTE] KIP-60: Make Java client class loading more flexible

+1 (binding) Ismael On Fri, Jul 1, 2016 at 12:27 PM, Rajini Sivaram < rajinisiva...@googlemail.com> wrote: > I would like to initiate the voting process for KIP-60 ( > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-60+-+Make+Java+client+classloading+more+flexible > ). > This is a

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361433#comment-15361433 ] Stevo Slavic commented on KAFKA-873: Even with latest 0.10.0.0 Kafka clients, explicit topic management

[GitHub] kafka pull request #1583: MINOR: fix generics in KStream.groupBy(...)

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1583 MINOR: fix generics in KStream.groupBy(...) The type param `V1` in the `KStream.groupBy(...)` methods is not needed. @guozhangwang You can merge this pull request into a Git repository by

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361397#comment-15361397 ] Flavio Junqueira commented on KAFKA-873: I see what you're saying. That support in in zkClient was

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361334#comment-15361334 ] Stevo Slavic commented on KAFKA-873: Compare

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361236#comment-15361236 ] Flavio Junqueira commented on KAFKA-873: [~mtomcat_sslavic] could be more specific about what

[jira] [Commented] (KAFKA-3910) Cyclic schema support in ConnectSchema and SchemaBuilder

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

[GitHub] kafka pull request #1582: KAFKA-3910: Cyclic schema support in ConnectSchema...

GitHub user johnhofman opened a pull request: https://github.com/apache/kafka/pull/1582 KAFKA-3910: Cyclic schema support in ConnectSchema and SchemaBuilder This feature uses a FutureSchema as a placeholder to be resolved later. Resolution is attempted whenever a ConnectSchema is

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361175#comment-15361175 ] Stevo Slavic commented on KAFKA-873: One pro-Curator benefit to note - it seems easier to provision

[jira] [Created] (KAFKA-3928) Support a list of partition field names

dennis lucero created KAFKA-3928: Summary: Support a list of partition field names Key: KAFKA-3928 URL: https://issues.apache.org/jira/browse/KAFKA-3928 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-67: Queryable state for Kafka Stream

Thanks Jay - i've updated the KIP accordingly. Thanks, Damian On Fri, 1 Jul 2016 at 16:19 Jay Kreps wrote: > We have not used the "get" prefex in methods, like getXyz(), elsewhere in > our java code, instead sticking with the scala style methods like xyz(). > It'd be good to

[jira] [Updated] (KAFKA-3927) kafka broker config docs issue

[ https://issues.apache.org/jira/browse/KAFKA-3927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shawn Guo updated KAFKA-3927: - Description: https://kafka.apache.org/documentation.html#brokerconfigs log.flush.interval.messages

[jira] [Created] (KAFKA-3927) kafka broker config docs issue

Shawn Guo created KAFKA-3927: Summary: kafka broker config docs issue Key: KAFKA-3927 URL: https://issues.apache.org/jira/browse/KAFKA-3927 Project: Kafka Issue Type: Bug Components: