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

Hi Guozhang, Yes the clock will be reset not extended. Sorry incorrect wording in the KIP. I'll update it. Thanks, Damian On Wed, 29 Mar 2017 at 23:18 Guozhang Wang wrote: > Made another pass over the KIP wiki, overall LGTM. One quick question on > the described logic: "they will be added to t

Re: [VOTE] KIP-120: Cleanup Kafka Streams builder API

Thanks Matthias. +1 On Thu, 23 Mar 2017 at 22:40 Matthias J. Sax wrote: > Hi, > > I would like to start the VOTE on KIP-120: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-120%3A+Cleanup+Kafka+Streams+builder+API > > If you have further comments, please reply to the DISCUSS thread. >

[jira] [Created] (KAFKA-4978) kafka.metrics.reporters missing from the documentation

Mickael Maison created KAFKA-4978: - Summary: kafka.metrics.reporters missing from the documentation Key: KAFKA-4978 URL: https://issues.apache.org/jira/browse/KAFKA-4978 Project: Kafka Issue

[jira] [Assigned] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4913: - Assignee: Damian Guy > creating a window store with one segment throws division by zero error > -

[GitHub] kafka pull request #2764: MINOR: reduce amount of verbose printing

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2764 MINOR: reduce amount of verbose printing You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-remove-verboseprint Altern

[GitHub] kafka pull request #2765: MINOR: Fix race condition in TestVerifiableProduce...

GitHub user edenhill opened a pull request: https://github.com/apache/kafka/pull/2765 MINOR: Fix race condition in TestVerifiableProducer sanity test The test starts a producer, waits for at least 5 acks, and then logs in to the worker to grep for the producer process to figure

[GitHub] kafka pull request #2766: KAFKA-4913: creating a window store with one segme...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2766 KAFKA-4913: creating a window store with one segment throws division by zero error Allow a window store with a single segment. If there is only one segment then set the cleanup.policy to compact. You

[jira] [Commented] (KAFKA-4913) creating a window store with one segment throws division by zero error

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

[jira] [Updated] (KAFKA-4913) creating a window store with one segment throws division by zero error

[ https://issues.apache.org/jira/browse/KAFKA-4913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4913: -- Status: Patch Available (was: Open) > creating a window store with one segment throws division by zero

[jira] [Created] (KAFKA-4979) Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly

Nacho Munoz created KAFKA-4979: -- Summary: Handcrafted JoinGroupRequest makes consumers on the same group to exit abruptly Key: KAFKA-4979 URL: https://issues.apache.org/jira/browse/KAFKA-4979 Project: Ka

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

Hi All, I'd like to start the voting thread on KIP-134: https://cwiki.apache.org/confluence/display/KAFKA/KIP-134%3A+Delay+initial+consumer+group+rebalance Thanks, Damian

[jira] [Created] (KAFKA-4980) testReprocessingFromScratch unit test failure

Eno Thereska created KAFKA-4980: --- Summary: testReprocessingFromScratch unit test failure Key: KAFKA-4980 URL: https://issues.apache.org/jira/browse/KAFKA-4980 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-4965) set internal.leave.group.on.close to false in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-4965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4965: -- Status: Patch Available (was: In Progress) > set internal.leave.group.on.close to false in KafkaStreams

[jira] [Created] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

Edoardo Comar created KAFKA-4981: Summary: Add connection-accept-rate and connection-prepare-rate metrics Key: KAFKA-4981 URL: https://issues.apache.org/jira/browse/KAFKA-4981 Project: Kafka

[jira] [Assigned] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

[ https://issues.apache.org/jira/browse/KAFKA-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4937: - Assignee: Damian Guy > Batch resetting offsets in Streams' StoreChangelogReader > ---

[GitHub] kafka pull request #2694: MINOR: FetchRequest.Builder maxBytes for version <...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2694 --- 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] [Commented] (KAFKA-4842) Streams integration tests occasionally fail with connection error

[ https://issues.apache.org/jira/browse/KAFKA-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948898#comment-15948898 ] Magnus Edenhill commented on KAFKA-4842: Happened again on a trunk PR, https://gi

Re: [VOTE] KIP-81: Bound Fetch memory usage in the consumer

Thanks for the suggestion. Currently, I can't think of a scenario when we would need multiple priority "levels". If in the future it makes sense to have some, I think we could just make the change without a new KIP as these APIs are not public. So I'd be more inclined to keep the boolean for now.

[jira] [Resolved] (KAFKA-1516) Producer Performance Test sends messages with bytes of 0x0

[ https://issues.apache.org/jira/browse/KAFKA-1516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1516. -- Resolution: Fixed Resolving this as support for passing custom message payloads is given in KAFKA-4432

[GitHub] kafka pull request #2709: MINOR: Map `mkString` format updated to default ja...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2709 --- 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-4902) Utils#delete should correctly handle I/O errors and symlinks

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

[GitHub] kafka pull request #2691: KAFKA-4902: Utils#delete should correctly handle I...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2691 --- 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] [Commented] (KAFKA-4902) Utils#delete should correctly handle I/O errors and symlinks

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

[GitHub] kafka pull request #2620: MINOR: Doc change related to ZK sasl configs

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2620 --- 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 #2595: MINOR: Fix typos in javadoc and code comments

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2595 --- 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 #2767: Vagrant provisioning fixes

GitHub user edenhill opened a pull request: https://github.com/apache/kafka/pull/2767 Vagrant provisioning fixes You can merge this pull request into a Git repository by running: $ git pull https://github.com/edenhill/kafka harden_provision Alternatively you can review and ap

[GitHub] kafka pull request #2768: KAFKA-4981 Add connection-accept-rate and connecti...

GitHub user edoardocomar opened a pull request: https://github.com/apache/kafka/pull/2768 KAFKA-4981 Add connection-accept-rate and connection-prepare-rate KAFKA-4981 Add connection-accept-rate and connection-prepare-rate metrics added metrics per network processor with the

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

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

[jira] [Created] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

Edoardo Comar created KAFKA-4982: Summary: Add listener tag to socket-server-metrics.connection-... metrics Key: KAFKA-4982 URL: https://issues.apache.org/jira/browse/KAFKA-4982 Project: Kafka

[jira] [Assigned] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-4982: Assignee: Edoardo Comar > Add listener tag to socket-server-metrics.connection-... metrics

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949036#comment-15949036 ] Edoardo Comar commented on KAFKA-4982: -- [~ijuma] does this need a kip ? > Add listen

[jira] [Commented] (KAFKA-4982) Add listener tag to socket-server-metrics.connection-... metrics

[ https://issues.apache.org/jira/browse/KAFKA-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949079#comment-15949079 ] Ismael Juma commented on KAFKA-4982: Yes. > Add listener tag to socket-server-metrics

[GitHub] kafka pull request #2769: KAFKA-4937: Batch resetting offsets in Streams' St...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2769 KAFKA-4937: Batch resetting offsets in Streams' StoreChangelogReader change `consumer.position` so that it always updates any partitions that need an update. Keep track of partitions that `seekToBeginn

[jira] [Commented] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

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

[jira] [Commented] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949128#comment-15949128 ] Magnus Edenhill commented on KAFKA-4476: Directed here from KAFKA-4482. Happened

[jira] [Created] (KAFKA-4983) Test failure: kafka.api.ConsumerBounceTest.testSubscribeWhenTopicUnavailable

Magnus Edenhill created KAFKA-4983: -- Summary: Test failure: kafka.api.ConsumerBounceTest.testSubscribeWhenTopicUnavailable Key: KAFKA-4983 URL: https://issues.apache.org/jira/browse/KAFKA-4983 Projec

[jira] [Updated] (KAFKA-4983) Test failure: kafka.api.ConsumerBounceTest.testSubscribeWhenTopicUnavailable

[ https://issues.apache.org/jira/browse/KAFKA-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magnus Edenhill updated KAFKA-4983: --- Description: The PR builder encountered this test failure: {{kafka.api.ConsumerBounceTest.test

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949221#comment-15949221 ] Edoardo Comar commented on KAFKA-4981: -- as per comments on the pull request, the 'pre

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949223#comment-15949223 ] Edoardo Comar commented on KAFKA-4981: -- Thanks I know the block is skipped for PLAIN

[jira] [Commented] (KAFKA-4981) Add connection-accept-rate and connection-prepare-rate metrics

[ https://issues.apache.org/jira/browse/KAFKA-4981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949229#comment-15949229 ] Edoardo Comar commented on KAFKA-4981: -- Hi [~ijuma] for the 3rd time today :-) ... do

[jira] [Created] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

Ait haj Slimane created KAFKA-4984: -- Summary: Unable to produce or consume when enabling authentication SASL/Kerberos Key: KAFKA-4984 URL: https://issues.apache.org/jira/browse/KAFKA-4984 Project: Ka

[jira] [Updated] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ait haj Slimane updated KAFKA-4984: --- Description: I have a problem while trying to produce or consume on kerberos enabled cluster.

[jira] [Updated] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ait haj Slimane updated KAFKA-4984: --- Priority: Critical (was: Major) > Unable to produce or consume when enabling authentication S

[DISCUSS] KIP-136: Add Listener name and Security Protocol name to SelectorMetrics tags

Hi all, We created KIP-136: Add Listener name and Security Protocol name to SelectorMetrics tags https://cwiki.apache.org/confluence/display/KAFKA/KIP-136%3A+Add+Listener+name+and+Security+Protocol+name+to+SelectorMetrics+tags Please help review the KIP. You feedback is appreciated! cheers, Ed

Re: [DISCUSS] KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user

Hi Ismael, I have updated the KIP. Let me know if everything looks fine then I will begin voting. Thanks, Mayuresh On Wed, Mar 29, 2017 at 9:06 AM, Mayuresh Gharat wrote: > Hi Ismael, > > I agree. I will change the compatibility para and start voting. > > Thanks, > > Mayuresh > > On Tue, Mar

[jira] [Commented] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949351#comment-15949351 ] lakshminarayanasyamala commented on KAFKA-4984: --- Hi Ait haj Slimane, Can yo

[jira] [Commented] (KAFKA-4984) Unable to produce or consume when enabling authentication SASL/Kerberos

[ https://issues.apache.org/jira/browse/KAFKA-4984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949356#comment-15949356 ] lakshminarayanasyamala commented on KAFKA-4984: --- Hi Ait haj Slimane, Can you

[GitHub] kafka pull request #2770: MINOR: Increase max.poll time for streams consumer...

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2770 MINOR: Increase max.poll time for streams consumers You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-increase-max-pol

[DISCUSS] KIP-137: Enhance TopicCommand --describe to show topics marked for deletion

Hi all, We created KIP-137: Enhance TopicCommand --describe to show topics marked for deletion https://cwiki.apache.org/confluence/display/KAFKA/KIP-137%3A+Enhance+TopicCommand+--describe+to+show+topics+marked+for+deletion Please help review the KIP. You feedback is appreciated! Thanks

[jira] [Commented] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949374#comment-15949374 ] Matthias J. Sax commented on KAFKA-4476: That's a different issues, and we have a

Re: [DISCUSS] KIP-136: Add Listener name and Security Protocol name to SelectorMetrics tags

Edo, Thanks for the proposal. This looks great to me. Cheers, Roger On Thu, Mar 30, 2017 at 8:51 AM, Edoardo Comar wrote: > Hi all, > > We created KIP-136: Add Listener name and Security Protocol name to > SelectorMetrics tags > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 136%

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

+1 On 3/30/17 3:46 AM, Damian Guy wrote: > Hi All, > > I'd like to start the voting thread on KIP-134: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-134%3A+Delay+initial+consumer+group+rebalance > > Thanks, > Damian > signature.asc Description: OpenPGP digital signature

[jira] [Created] (KAFKA-4985) kafka-acls should resolve dns names and accept ip ranges

Ryan P created KAFKA-4985: - Summary: kafka-acls should resolve dns names and accept ip ranges Key: KAFKA-4985 URL: https://issues.apache.org/jira/browse/KAFKA-4985 Project: Kafka Issue Type: Improvem

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

+1 (non binding) Thanks Eno > On 30 Mar 2017, at 18:01, Matthias J. Sax wrote: > > +1 > > On 3/30/17 3:46 AM, Damian Guy wrote: >> Hi All, >> >> I'd like to start the voting thread on KIP-134: >> https://cwiki.apache.org/confluence/display/KAFKA/KIP-134%3A+Delay+initial+consumer+group+rebalanc

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

+1(non-binding) On Thu, Mar 30, 2017 at 1:30 PM, Eno Thereska wrote: > +1 (non binding) > > Thanks > Eno > > On 30 Mar 2017, at 18:01, Matthias J. Sax wrote: > > > > +1 > > > > On 3/30/17 3:46 AM, Damian Guy wrote: > >> Hi All, > >> > >> I'd like to start the voting thread on KIP-134: > >> http

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hi, Dong, Ok, so it seems that in solution (2), if the tool exits successfully, then we know for sure that all replicas will be in the right log dirs. Solution (1) doesn't guarantee that. That seems better and we can go with your current solution then. Thanks, Jun On Fri, Mar 24, 2017 at 4:28 P

[GitHub] kafka pull request #2761: KAFKA-4692: Make testNo thread safe

Github user original-brownbear closed the pull request at: https://github.com/apache/kafka/pull/2761 --- 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 fea

[jira] [Commented] (KAFKA-4692) Transient test failure in org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949491#comment-15949491 ] ASF GitHub Bot commented on KAFKA-4692: --- Github user original-brownbear closed the p

[GitHub] kafka pull request #2760: KAFKA-4973; Fix transient failure of AdminClientTe...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2760 --- 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] [Commented] (KAFKA-4973) Transient failure of AdminClientTest.testDeleteRecordsWithException

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

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hey Jun, Thanks much for the comment! Do you think we start vote for KIP-112 and KIP-113 if there is no further concern? Dong On Thu, Mar 30, 2017 at 10:40 AM, Jun Rao wrote: > Hi, Dong, > > Ok, so it seems that in solution (2), if the tool exits successfully, then > we know for sure that all

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

[ https://issues.apache.org/jira/browse/KAFKA-4689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949526#comment-15949526 ] Jason Gustafson commented on KAFKA-4689: I think I finally see what is happening h

[GitHub] kafka pull request #2771: KAFKA-4689: Disable system tests for consumer hard...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2771 KAFKA-4689: Disable system tests for consumer hard failures See the JIRA for the full details. Essentially the test assertions depend on receiving reliable events from the consumer processes, but

[jira] [Commented] (KAFKA-4689) OffsetValidationTest fails validation with "Current position greater than the total number of consumed records"

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

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

See Changes: [ismael] MINOR: FetchRequest.Builder maxBytes for version <3 -- [...truncated 1.54 MB...] org.apache.kafka.streams.state.internals.ChangeLoggingSegmentedByte

[GitHub] kafka pull request #2653: MINOR: Update possible errors in OffsetFetchRespon...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2653 --- 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] KIP-134: Delay initial consumer group rebalance

Damian, could you create a new thread for the voting process? Thanks! Guozhang On Thu, Mar 30, 2017 at 10:33 AM, Bill Bejeck wrote: > +1(non-binding) > > On Thu, Mar 30, 2017 at 1:30 PM, Eno Thereska > wrote: > > > +1 (non binding) > > > > Thanks > > Eno > > > On 30 Mar 2017, at 18:01, Matthi

[jira] [Assigned] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-4980: Assignee: Matthias J. Sax > testReprocessingFromScratch unit test failure > ---

[GitHub] kafka pull request #2772: KAFKA-4208: Add Record Headers

GitHub user michaelandrepearce opened a pull request: https://github.com/apache/kafka/pull/2772 KAFKA-4208: Add Record Headers As per KIP-82 Adding record headers api to ProducerRecord, ConsumerRecord Support to convert from protocol to api added Kafka Producer, Kafka Fe

[jira] [Commented] (KAFKA-4208) Add Record Headers

[ https://issues.apache.org/jira/browse/KAFKA-4208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949654#comment-15949654 ] ASF GitHub Bot commented on KAFKA-4208: --- GitHub user michaelandrepearce opened a pul

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

Hi Guozhang, This was a new thread! Damian On Thu, 30 Mar 2017 at 19:34, Guozhang Wang wrote: > Damian, could you create a new thread for the voting process? > > Thanks! > > Guozhang > > On Thu, Mar 30, 2017 at 10:33 AM, Bill Bejeck wrote: > > > +1(non-binding) > > > > On Thu, Mar 30, 2017 at 1

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

+1 Sorry about the previous email, Gmail seems be collapsing them into a single thread on my inbox. Guozhang On Thu, Mar 30, 2017 at 11:34 AM, Guozhang Wang wrote: > Damian, could you create a new thread for the voting process? > > Thanks! > > Guozhang > > On Thu, Mar 30, 2017 at 10:33 AM, Bil

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

+1 Thanks for the KIP! On Thu, Mar 30, 2017 at 12:51 PM, Guozhang Wang wrote: > +1 > > Sorry about the previous email, Gmail seems be collapsing them into a > single thread on my inbox. > > Guozhang > > On Thu, Mar 30, 2017 at 11:34 AM, Guozhang Wang > wrote: > > > Damian, could you create a ne

[jira] [Updated] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4980: --- Status: Patch Available (was: Open) > testReprocessingFromScratch unit test failure > ---

[jira] [Commented] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949694#comment-15949694 ] Matthias J. Sax commented on KAFKA-4980: PR: https://github.com/apache/kafka/pull/

Re: [VOTE] KIP-129: Kafka Streams Exactly-Once Semantics

+1 I am closing this vote now. The KIP got accepted with +3 binding (Jason, Jay, Ram) and +6 non-binding (Eno, Damian, Apruva, Bill, Michael, Matthias) votes. Thanks for voting! -Matthias On 3/29/17 10:27 AM, Michael Noll wrote: > +1 (non-binding) > > On Wed, Mar 29, 2017 at 6:38 PM, Sriram

[jira] [Updated] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4980: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request #2757: KAFKA-4980: testReprocessingFromScratch unit test ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2757 --- 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] [Commented] (KAFKA-4980) testReprocessingFromScratch unit test failure

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

Re: [DISCUSS] KIP-86: Configurable SASL callback handlers

I have made a minor change to the callback handler interface to pass in the JAAS configuration entries in *configure,* to work with the multiple listener configuration introduced in KIP-103. I have also renamed the interface to AuthenticateCallbackHandler instead of AuthCallbackHandler to avoid con

[GitHub] kafka pull request #2764: MINOR: reduce amount of verbose printing

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2764 --- 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 #2773: Add exactly-once config to StreamsConfig

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2773 Add exactly-once config to StreamsConfig Enable producer per task if exactly-once config is enabled. You can merge this pull request into a Git repository by running: $ git pull https://github.co

[jira] [Created] (KAFKA-4986) Add producer per task support

Matthias J. Sax created KAFKA-4986: -- Summary: Add producer per task support Key: KAFKA-4986 URL: https://issues.apache.org/jira/browse/KAFKA-4986 Project: Kafka Issue Type: Sub-task

[jira] [Work started] (KAFKA-4923) Add Exactly-Once Semantics

[ https://issues.apache.org/jira/browse/KAFKA-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4923 started by Matthias J. Sax. -- > Add Exactly-Once Semantics > -- > >

[jira] [Created] (KAFKA-4987) Topic creation allows invalid config values on running brokers

dan norwood created KAFKA-4987: -- Summary: Topic creation allows invalid config values on running brokers Key: KAFKA-4987 URL: https://issues.apache.org/jira/browse/KAFKA-4987 Project: Kafka Iss

[jira] [Updated] (KAFKA-4986) Add producer per task support

[ https://issues.apache.org/jira/browse/KAFKA-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4986: --- Assignee: Matthias J. Sax Status: Patch Available (was: Open) https://github.com/apache

[jira] [Updated] (KAFKA-4986) Add producer per task support

[ https://issues.apache.org/jira/browse/KAFKA-4986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4986: --- Description: Add new config parameter {{processing_guarantee}} and enable "producer per task"

[jira] [Updated] (KAFKA-4987) Topic creation allows invalid config values on running brokers

[ https://issues.apache.org/jira/browse/KAFKA-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dan norwood updated KAFKA-4987: --- Affects Version/s: 0.10.0.1 > Topic creation allows invalid config values on running brokers > ---

[GitHub] kafka pull request #2762: MINOR: Ensure streaming iterator is closed by Fetc...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2762 --- 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 #2767: Vagrant provisioning fixes

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2767 --- 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] [Created] (KAFKA-4988) JVM crash when running on Alpine Linux

Vincent Rischmann created KAFKA-4988: Summary: JVM crash when running on Alpine Linux Key: KAFKA-4988 URL: https://issues.apache.org/jira/browse/KAFKA-4988 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4344) Exception when accessing partition, offset and timestamp in processor class

[ https://issues.apache.org/jira/browse/KAFKA-4344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949949#comment-15949949 ] saiprasad mishra commented on KAFKA-4344: - Hi All Lot of people reached out to me

[jira] [Commented] (KAFKA-4810) SchemaBuilder should be more lax about checking that fields are unset if they are being set to the same value

[ https://issues.apache.org/jira/browse/KAFKA-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949951#comment-15949951 ] Ewen Cheslack-Postava commented on KAFKA-4810: -- [~pshk4r] Great! You're alrea

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hi, Dong, I don't have further concerns. If there are no more comments from other people, we can start the vote. Thanks, Jun On Thu, Mar 30, 2017 at 10:59 AM, Dong Lin wrote: > Hey Jun, > > Thanks much for the comment! Do you think we start vote for KIP-112 and > KIP-113 if there is no furthe

[jira] [Updated] (KAFKA-4987) Topic creation allows invalid config values on running brokers

[ https://issues.apache.org/jira/browse/KAFKA-4987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dan norwood updated KAFKA-4987: --- Affects Version/s: (was: 0.10.2.0) > Topic creation allows invalid config values on running broker

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hi all, Thanks for all the comments. I am going to open the voting thread if there is no further concern with the KIP. Dong On Wed, Mar 15, 2017 at 5:25 PM, Ismael Juma wrote: > Thanks for the updates Dong, they look good to me. > > Ismael > > On Wed, Mar 15, 2017 at 5:50 PM, Dong Lin wrote:

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Thanks Jun! Hi all, Thanks for all the comments. I am going to open the voting thread if there is no further concern with the KIP. Dong On Thu, Mar 30, 2017 at 3:19 PM, Jun Rao wrote: > Hi, Dong, > > I don't have further concerns. If there are no more comments from other > people, we can star

[GitHub] kafka pull request #2618: KAFKA-4791: unable to add state store with regex m...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2618 --- 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] [Commented] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

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

[jira] [Updated] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

[ https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4791: - Resolution: Fixed Fix Version/s: 0.10.2.1 0.11.0.0 Status: Res

  1   2   >