[jira] [Commented] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965448#comment-15965448 ] Bharad Tirumala commented on KAFKA-5038: [~enothereska], I tried the fix and it se

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

See Changes: [ismael] MINOR: Make LeaderAndIsr immutable case class [cshapi] MINOR: Added changes in 0.10.2.1 -- [...truncated 933.49 KB...] org.apache.kafka.streams.sta

Topic Creation programatically

Hi Team, I am using kafka integrated with java client. I have a question " What is the best practice to create topic using programmatically or using CLI topic creation command?" Thanks, Zishan Ali

Can't start zookeeper and Kafka server

Hi kafka, I placed my kafka source in "*C:\kafka_2.9.1-0.8.2.2*" ,Open command prompt as Administrator . moved to " *C:\kafka_2.9.1-0.8.2.2\bin\windows*" . now execute command "* zookeeper-server-start.bat ..\..\config\zookeeper.properties*" im getting following error. *The system cannot

[GitHub] kafka pull request #2844: HOTFIX: HTML formatting error in upgrade docs from...

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/2844 HOTFIX: HTML formatting error in upgrade docs from pr-2824 Already fixed in the website github You can merge this pull request into a Git repository by running: $ git pull https://github.com/g

Jenkins build is back to normal : kafka-trunk-jdk8 #1422

See

[jira] [Created] (KAFKA-5057) "Big Message Log"

Gwen Shapira created KAFKA-5057: --- Summary: "Big Message Log" Key: KAFKA-5057 URL: https://issues.apache.org/jira/browse/KAFKA-5057 Project: Kafka Issue Type: Bug Reporter: Gwen Shap

Re: [VOTE] 0.10.2.1 RC0

Wrong link :) http://kafka.apache.org/documentation/#upgrade and http://kafka.apache.org/documentation/streams#streams_api_changes_0102 On Tue, Apr 11, 2017 at 5:57 PM, Gwen Shapira wrote: > FYI: I just updated the upgrade notes with Streams changes: > http://kafka.apache.org/documentation/#getti

Re: [VOTE] 0.10.2.1 RC0

FYI: I just updated the upgrade notes with Streams changes: http://kafka.apache.org/documentation/#gettingStarted On Fri, Apr 7, 2017 at 5:12 PM, Gwen Shapira wrote: > Hello Kafka users, developers and client-developers, > > This is the first candidate for the release of Apache Kafka 0.10.2.1. Th

[jira] [Updated] (KAFKA-5056) Shuffling of partitions in old consumer fetch requests removed

[ https://issues.apache.org/jira/browse/KAFKA-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Todd Palino updated KAFKA-5056: --- Summary: Shuffling of partitions in old consumer fetch requests removed (was: Shuffling of partitions

[GitHub] kafka pull request #2843: KAFKA-5056: Add shuffling of FetchRequest requestI...

GitHub user toddpalino opened a pull request: https://github.com/apache/kafka/pull/2843 KAFKA-5056: Add shuffling of FetchRequest requestInfo back to old consumer KIP-74 removed the shuffle of requestInfo from the FetchRequest constructor, moving the logic to the replica fetcher and

[jira] [Commented] (KAFKA-5056) Shuffling of partitions in old consume fetch requests removed

[ https://issues.apache.org/jira/browse/KAFKA-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965198#comment-15965198 ] ASF GitHub Bot commented on KAFKA-5056: --- GitHub user toddpalino opened a pull reques

[jira] [Updated] (KAFKA-5056) Shuffling of partitions in old consume fetch requests removed

[ https://issues.apache.org/jira/browse/KAFKA-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Todd Palino updated KAFKA-5056: --- Reviewer: Joel Koshy Status: Patch Available (was: In Progress) > Shuffling of partitions in ol

[jira] [Work started] (KAFKA-5056) Shuffling of partitions in old consume fetch requests removed

[ https://issues.apache.org/jira/browse/KAFKA-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5056 started by Todd Palino. -- > Shuffling of partitions in old consume fetch requests removed > ---

[jira] [Created] (KAFKA-5056) Shuffling of partitions in old consume fetch requests removed

Todd Palino created KAFKA-5056: -- Summary: Shuffling of partitions in old consume fetch requests removed Key: KAFKA-5056 URL: https://issues.apache.org/jira/browse/KAFKA-5056 Project: Kafka Issu

[jira] [Resolved] (KAFKA-4997) Issue with running kafka-acls.sh when using SASL between Kafka and ZK

[ https://issues.apache.org/jira/browse/KAFKA-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shrikant resolved KAFKA-4997. - Resolution: Not A Problem > Issue with running kafka-acls.sh when using SASL between Kafka and ZK > --

[jira] [Commented] (KAFKA-4997) Issue with running kafka-acls.sh when using SASL between Kafka and ZK

[ https://issues.apache.org/jira/browse/KAFKA-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965186#comment-15965186 ] Shrikant commented on KAFKA-4997: - Rajini, Thanks for response. Figure out the issue, al

[GitHub] kafka pull request #2824: MINOR: Added changes in 0.10.2.1

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

Re: [VOTE] 0.10.2.1 RC0

Thanks for the feedback. I'm not super familiar with the inner workings of Apache's Maven repos, so I can't explain why we do things the way we do. I followed the same process on all Apache projects I was on (Kafka, Sqoop, Flume). Do you know projects that do things the way you suggested? Either

[GitHub] kafka pull request #2731: MINOR: Make LeaderAndIsr immutable case class.

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

[GitHub] kafka pull request #2842: MINOR: findbugs should generate XML reports

GitHub user cmccabe opened a pull request: https://github.com/apache/kafka/pull/2842 MINOR: findbugs should generate XML reports You can merge this pull request into a Git repository by running: $ git pull https://github.com/cmccabe/kafka findbugs-xml Alternatively you can re

[jira] [Commented] (KAFKA-5013) Fail the build when findbugs fails

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

[GitHub] kafka pull request #2805: KAFKA-5013. Fail the build when findbugs fails

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

[jira] [Resolved] (KAFKA-5013) Fail the build when findbugs fails

[ https://issues.apache.org/jira/browse/KAFKA-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5013. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2805 [https://github

Re: [VOTE] 0.10.2.1 RC0

> On Apr 7, 2017, at 5:12 PM, Gwen Shapira wrote: > > Hello Kafka users, developers and client-developers, > > This is the first candidate for the release of Apache Kafka 0.10.2.1. This > is a bug fix release and it includes fixes and improvements from 24 JIRAs > (including a few critical bugs)

[jira] [Commented] (KAFKA-5011) Replica fetchers may need to down-convert messages during a selective message format upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964994#comment-15964994 ] Joel Koshy commented on KAFKA-5011: --- Yes that is correct - it is rare. I think it's reas

[jira] [Work started] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5038 started by Eno Thereska. --- > running multiple kafka streams instances causes one or more instance to get > in

[jira] [Assigned] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5038: --- Assignee: Eno Thereska > running multiple kafka streams instances causes one or more instance

[jira] [Commented] (KAFKA-4930) Connect Rest API allows creating connectors with an empty name

[ https://issues.apache.org/jira/browse/KAFKA-4930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964886#comment-15964886 ] Sönke Liebau commented on KAFKA-4930: - [~gwenshap]: Did you have a chance yet to have

[jira] [Commented] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964883#comment-15964883 ] Eno Thereska commented on KAFKA-5038: - [~btirumala] thank you for posting. Looks like

Re: [DISCUSS] KIP-138: Change punctuate semantics

Here's an example that we currently have. We have a streams processor that does a transform from one topic into another. One of the fields in the source topic record is an expiration time, and one of the functions of the processor is to ensure that expired records get deleted promptly after that t

[jira] [Commented] (KAFKA-5038) running multiple kafka streams instances causes one or more instance to get into file contention

[ https://issues.apache.org/jira/browse/KAFKA-5038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964881#comment-15964881 ] ASF GitHub Bot commented on KAFKA-5038: --- GitHub user enothereska opened a pull reque

[GitHub] kafka pull request #2841: KAFKA-5038: Catch exception

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2841 KAFKA-5038: Catch exception You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5038 Alternatively you can review and a

[jira] [Created] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

Nikki Thean created KAFKA-5055: -- Summary: Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor Key: KAFKA-5055 URL: https://issues.apache.org/jira/b

[jira] [Comment Edited] (KAFKA-4988) JVM crash when running on Alpine Linux

[ https://issues.apache.org/jira/browse/KAFKA-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964809#comment-15964809 ] Murad M edited comment on KAFKA-4988 at 4/11/17 6:55 PM: - Just fac

[jira] [Commented] (KAFKA-4988) JVM crash when running on Alpine Linux

[ https://issues.apache.org/jira/browse/KAFKA-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964809#comment-15964809 ] Murad M commented on KAFKA-4988: Just faced same problem here. Running application in full

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

+1 On 4/11/17 10:34 AM, Eno Thereska wrote: > Hi Matthias, > > >> On 11 Apr 2017, at 09:41, Matthias J. Sax wrote: >> >> Not sure, if we are on the same page already? >> >>> "A __store__ can be queryable whether is't materialized or not" >> >> This does not make sense -- there is nothing like a

[jira] [Commented] (KAFKA-4818) Implement transactional clients

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

[GitHub] kafka pull request #2840: KAFKA-4818: Exactly once transactional clients

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/2840 KAFKA-4818: Exactly once transactional clients You can merge this pull request into a Git repository by running: $ git pull https://github.com/apurvam/kafka exactly-once-transactional-clients

[jira] [Updated] (KAFKA-4818) Implement transactional clients

[ https://issues.apache.org/jira/browse/KAFKA-4818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-4818: Description: This covers the implementation of the producer and consumer to support transactions.

[jira] [Updated] (KAFKA-4818) Implement transactional clients

[ https://issues.apache.org/jira/browse/KAFKA-4818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-4818: Description: This covers the implementation of the producer and consumer to support transactions, as

[jira] [Assigned] (KAFKA-4818) Implement transactional producer

[ https://issues.apache.org/jira/browse/KAFKA-4818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-4818: --- Assignee: Apurva Mehta (was: Guozhang Wang) > Implement transactional producer > ---

[jira] [Commented] (KAFKA-4967) java.io.EOFException Error while committing offsets

[ https://issues.apache.org/jira/browse/KAFKA-4967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964757#comment-15964757 ] Upendra Yadav commented on KAFKA-4967: -- I solved this issue by calling 2nd time commi

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Matthias, > On 11 Apr 2017, at 09:41, Matthias J. Sax wrote: > > Not sure, if we are on the same page already? > >> "A __store__ can be queryable whether is't materialized or not" > > This does not make sense -- there is nothing like a non-materialized > store -- only non-materialized KTab

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Not sure, if we are on the same page already? > "A __store__ can be queryable whether is't materialized or not" This does not make sense -- there is nothing like a non-materialized store -- only non-materialized KTables. > "Yes, there is nothing that will prevent users from querying internally g

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Matthias, See my note: "A store can be queryable whether it's materialized or not". I think we're on the same page. Stores with an internal name are also queryable. I'm just pointing out that. although that is the case today and with this KIP, I don't think we have an obligation to make sto

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

+1 on including GlobalKTable But I am not sure about the materialization / queryable question. For full consistency, all KTables should be queryable nevertheless if they are materialized or not. -- Maybe this is a second step though (even if I would like to get this done right away) If we don't w

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

KIP updated, thank you. Eno > On 11 Apr 2017, at 08:23, Damian Guy wrote: > > Eno, re: GlobalKTable - yeah that seems fine. > > On Tue, 11 Apr 2017 at 14:18 Eno Thereska wrote: > >> About GlobalKTables, I suppose there is no reason why they cannot also use >> this KIP for consistency, e.g.,

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Eno, re: GlobalKTable - yeah that seems fine. On Tue, 11 Apr 2017 at 14:18 Eno Thereska wrote: > About GlobalKTables, I suppose there is no reason why they cannot also use > this KIP for consistency, e.g., today you have: > > public GlobalKTable globalTable(final Serde keySerde, >

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

About GlobalKTables, I suppose there is no reason why they cannot also use this KIP for consistency, e.g., today you have: public GlobalKTable globalTable(final Serde keySerde, final Serde valSerde, final S

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Michael, comments inline: > On 11 Apr 2017, at 03:25, Michael Noll wrote: > > Thanks for the updates, Eno! > > In addition to what has already been said: We should also explicitly > mention that this KIP is not touching GlobalKTable. I'm sure that some > users will throw KTable and GlobalK

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Damian, Thanks. I agree, I'll adjust the tone so it's more about querying, while materialisation is an internal concept. If no store name is provided, the user would still be able to discover the store, however we are not making any strong guarantees in that case, since after all it i an in

Re: [DISCUSS] KIP-138: Change punctuate semantics

I apologize for the longer email below. To my defense, it started out much shorter. :-) Also, to be super-clear, I am intentionally playing devil's advocate for a number of arguments brought forth in order to help improve this KIP -- I am not implying I necessarily disagree with the arguments. T

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

See Changes: [ismael] KAFKA-4866; Console consumer `print.value` property is ignored -- [...truncated 112.75 KB...] kafka.api.PlaintextProducerSendTest > testSendWithInval

[GitHub] kafka pull request #2661: kafka-4866: Kafka console consumer property is ign...

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

[jira] [Resolved] (KAFKA-4866) Kafka console consumer property is ignored

[ https://issues.apache.org/jira/browse/KAFKA-4866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4866. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2661 [https://github

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

See Changes: [ismael] MINOR: Fix typo in consumer ACL example -- [...truncated 116.86 KB...] kafka.api.ProducerFailureHandlingTest > testTooLargeRecordWithAckOne STARTED

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

See Changes: [ismael] KAFKA-5043; Rename GroupCoordinator to FindCoordinator (KIP-98) [ismael] MINOR: Document ordering contract of iterator for window stores and -- [...

[GitHub] kafka pull request #2839: Fix typo - Acls Examples, Adding or removing a pri...

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

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Thanks for the updates, Eno! In addition to what has already been said: We should also explicitly mention that this KIP is not touching GlobalKTable. I'm sure that some users will throw KTable and GlobalKTable into one conceptual "it's all tables!" bucket and then wonder how the KIP might affect

[GitHub] kafka-site issue #54: Fix typo - Acls Examples, Adding or removing a princip...

Github user sunnykrGupta commented on the issue: https://github.com/apache/kafka-site/pull/54 Sure. Did PR https://github.com/apache/kafka/pull/2839 . :) --- 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 d

[GitHub] kafka pull request #2839: Fix typo - Acls Examples, Adding or removing a pri...

GitHub user sunnykrGupta opened a pull request: https://github.com/apache/kafka/pull/2839 Fix typo - Acls Examples, Adding or removing a principal as producer … …or consumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/sunn

[GitHub] kafka pull request #2751: MINOR: Document ordering contract of iterator for ...

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

[GitHub] kafka-site issue #54: Fix typo - Acls Examples, Adding or removing a princip...

Github user ijuma commented on the issue: https://github.com/apache/kafka-site/pull/54 Thanks for the PR, can you do a PR to the code repo https://github.com/apache/kafka/tree/trunk/docs? --- If your project is set up for it, you can reply to this email and have your reply appear on

[GitHub] kafka-site issue #54: Fix typo - Acls Examples, Adding or removing a princip...

Github user omkreddy commented on the issue: https://github.com/apache/kafka-site/pull/54 LGTM --- 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 fe

[jira] [Commented] (KAFKA-5043) Add FindCoordinatorRequest RPC stub and update InitPidRequest for KIP-98

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

[GitHub] kafka pull request #2825: KAFKA-5043 : Add FindCoordinatorRPC stub and updat...

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

[jira] [Resolved] (KAFKA-5043) Add FindCoordinatorRequest RPC stub and update InitPidRequest for KIP-98

[ https://issues.apache.org/jira/browse/KAFKA-5043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5043. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2825 [https://github

[jira] [Commented] (KAFKA-3355) GetOffsetShell command doesn't work with SASL enabled Kafka

[ https://issues.apache.org/jira/browse/KAFKA-3355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963998#comment-15963998 ] Mohammed amine GARMES commented on KAFKA-3355: -- Hello [~fredji], this fix is

[GitHub] kafka-site pull request #54: Fix typo - Acls Examples, Adding or removing a ...

GitHub user sunnykrGupta opened a pull request: https://github.com/apache/kafka-site/pull/54 Fix typo - Acls Examples, Adding or removing a principal as producer … …or consumer You can merge this pull request into a Git repository by running: $ git pull https://github.com/s

[jira] [Assigned] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

[ https://issues.apache.org/jira/browse/KAFKA-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5054: - Assignee: Damian Guy > ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchroniz

[jira] [Created] (KAFKA-5054) ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized

Damian Guy created KAFKA-5054: - Summary: ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized Key: KAFKA-5054 URL: https://issues.apache.org/jira/browse/KAFKA-5054 Project: Kafka

Re: [VOTE] KIP-134: Delay initial consumer group rebalance

Hi Onur, It was in my previous email. But here it is again. 1. Better rebalance timing. We will try to rebalance only when all the consumers in a group have joined. The challenge would be someone has to define what does ALL consumers m

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Hi Florian, Thanks for the updates. The KIP is looking good. Cheers, Damian On Fri, 7 Apr 2017 at 22:41 Matthias J. Sax wrote: > What about KafkaStreams#toString() method? > > I think, we want to deprecate it as with KIP-120 and the changes of this > KIP, is gets obsolete. > > If we do so, ple

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Eno, Thanks for the update. I agree with what Matthias said. I wonder if the KIP should talk less about materialization and more about querying? After all, that is what is being provided from an end-users perspective. I think if no store name is provided users would still be able to query the