Re: [kafka-clients] [VOTE] 0.10.1.0 RC3

+1 -- passes kafka-python integration tests On Mon, Oct 17, 2016 at 1:28 PM, Jun Rao wrote: > Thanks for preparing the release. Verified quick start on scala 2.11 binary. > +1 > > Jun > > On Fri, Oct 14, 2016 at 4:29 PM, Jason Gustafson wrote: >> >> Hello

Re: [kafka-clients] [VOTE] 0.10.1.0 RC3

+1 (non-binding) verified quick start and artifacts. On Sat, Oct 15, 2016 at 4:59 AM, Jason Gustafson wrote: > Hello Kafka users, developers and client-developers, > > One more RC for 0.10.1.0. We're hoping this is the final one so that we > can meet the release target date

[jira] [Updated] (KAFKA-4275) Check of State-Store-assignment to Processor-Nodes is not enabled

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

[jira] [Commented] (KAFKA-4275) Check of State-Store-assignment to Processor-Nodes is not enabled

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

[GitHub] kafka pull request #1992: KAFKA-4275: Check of State-Store-assignment to Pro...

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

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

See

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584156#comment-15584156 ] Nacho Solis commented on KAFKA-1351: Thanks [~jjkoshy]. Yes, this is a pet peeve of mine. Logging

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

See Changes: [jason] MINOR: Code refactor - cleaning up some boolean assignments -- [...truncated 1266 lines...] kafka.admin.TopicCommandTest > testConfigPreservationAcrossPartitionAlteration

[GitHub] kafka pull request #2013: MINOR: Code refactor - cleaning up some boolean as...

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

[GitHub] kafka pull request #2013: MINOR: Code refactor - cleaning up some boolean as...

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

[GitHub] kafka pull request #2013: MINOR: Code refactor - cleaning up some boolean as...

GitHub user imandhan reopened a pull request: https://github.com/apache/kafka/pull/2013 MINOR: Code refactor - cleaning up some boolean assignments You can merge this pull request into a Git repository by running: $ git pull https://github.com/imandhan/kafka KAFKA-refactor

Re: KStreams / add support for sink processor with dynamic topics

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Hi, using DSL you cannot do this. However, if you use Processor API you can. There are similar question on the mailing list already. For example: http://search-hadoop.com/m/uyzND1lghNN1tzbf41=kafka+stream+to+new+t opic+based+on+message+key As we

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583851#comment-15583851 ] Joel Koshy commented on KAFKA-1351: --- Yes - this is still an issue. cc [~nsolis] > String.format is very

[jira] [Resolved] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4225. Resolution: Fixed > Replication Quotas: Control Leader & Follower Limit Separately >

[jira] [Reopened] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reopened KAFKA-4225: > Replication Quotas: Control Leader & Follower Limit Separately >

[jira] [Closed] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson closed KAFKA-4225. -- Not sure why this is no longer marked "resolved," but closing now. > Replication Quotas: Control

[jira] [Updated] (KAFKA-4225) Replication Quotas: Control Leader & Follower Limit Separately

[ https://issues.apache.org/jira/browse/KAFKA-4225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4225: --- Status: Resolved (was: Closed) > Replication Quotas: Control Leader & Follower Limit

[jira] [Commented] (KAFKA-4309) Allow "pluggable" properties in KafkaService in System Tests

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

[GitHub] kafka pull request #2034: KAFKA-4309: Allow "pluggable" properties in KafkaS...

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/2034 KAFKA-4309: Allow "pluggable" properties in KafkaService in System Tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/benstopford/kafka

Stream processing meetup at LinkedIn (Sunnyvale) on Wednesday, November 2 at 6pm

Hi everyone, We would like to invite you to a Stream Processing Meetup at LinkedIn’s Sunnyvale campus on Wednesday, November 2 at 6pm. Please RSVP here (if you intend to attend in person): http://www.meetup.com/Stream-Processing-Meetup-LinkedIn/events/234454163 We have the following three talks

[jira] [Created] (KAFKA-4309) Allow "pluggable" properties in KafkaService in System Tests

Ben Stopford created KAFKA-4309: --- Summary: Allow "pluggable" properties in KafkaService in System Tests Key: KAFKA-4309 URL: https://issues.apache.org/jira/browse/KAFKA-4309 Project: Kafka

[jira] [Commented] (KAFKA-2602) Incorrect descriptions about serializers for ProducerConfig in 0.8.2 and 0.8.3 documentation

[ https://issues.apache.org/jira/browse/KAFKA-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583514#comment-15583514 ] Andrew Musselman commented on KAFKA-2602: - [~hachikuji] [~ijuma] [~junrao] [~granthenke] any

KStreams / add support for sink processor with dynamic topics

Hi All, Currently, it seems not possible with KStream to produce messages to topics which are not known until runtime. For a new project I am evaluating the Kafka Connect / Kafka Streams architecture but without that feature I cannot retain the KStreams API. Our use case is pretty basic. We

[GitHub] kafka pull request #2033: Documentation for Throttled Replication

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/2033 Documentation for Throttled Replication You can merge this pull request into a Git repository by running: $ git pull https://github.com/benstopford/kafka throttling-docs Alternatively

Re: [kafka-clients] [VOTE] 0.10.1.0 RC3

Thanks for preparing the release. Verified quick start on scala 2.11 binary. +1 Jun On Fri, Oct 14, 2016 at 4:29 PM, Jason Gustafson wrote: > Hello Kafka users, developers and client-developers, > > One more RC for 0.10.1.0. We're hoping this is the final one so that we >

[jira] [Commented] (KAFKA-2602) Incorrect descriptions about serializers for ProducerConfig in 0.8.2 and 0.8.3 documentation

[ https://issues.apache.org/jira/browse/KAFKA-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583338#comment-15583338 ] Zhuo Liu commented on KAFKA-2602: - Hi [~andrew.musselman], I see one fix here

[jira] [Commented] (KAFKA-3745) Consider adding join key to ValueJoiner interface

[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583262#comment-15583262 ] Matthias J. Sax commented on KAFKA-3745: Yes. AFAIK, we got more request for this. > Consider

Re: delete topic causing spikes in fetch/metadata requests

These errors are possibly caused by delete topic (esp. using v0.8.2.x), refer below issues. https://issues.apache.org/jira/browse/KAFKA-2231 https://issues.apache.org/jira/browse/KAFKA-1194 The replica fetchers still querying their leaders for partitions of deleted topic. May need a restart of

[jira] [Commented] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583196#comment-15583196 ] Andrew Musselman commented on KAFKA-3545: - Not sure who to notifiy for closing tickets;

[jira] [Commented] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583149#comment-15583149 ] Greg Fodor commented on KAFKA-3545: --- Yes > Generalized Serdes for List/Map >

[jira] [Resolved] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Fodor resolved KAFKA-3545. --- Resolution: Fixed Fix Version/s: 0.10.1.0 > Generalized Serdes for List/Map >

[jira] [Commented] (KAFKA-2111) Command Line Standardization - Add Help Arguments & List Required Fields

[ https://issues.apache.org/jira/browse/KAFKA-2111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583142#comment-15583142 ] Andrew Musselman commented on KAFKA-2111: - [~mwarhaftig] any progress on this; are we keeping this

[jira] [Commented] (KAFKA-3545) Generalized Serdes for List/Map

[ https://issues.apache.org/jira/browse/KAFKA-3545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583131#comment-15583131 ] Andrew Musselman commented on KAFKA-3545: - [~guozhang] and [~gfodor] looks like the two tickets

[jira] [Commented] (KAFKA-3745) Consider adding join key to ValueJoiner interface

[ https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583079#comment-15583079 ] Andrew Musselman commented on KAFKA-3745: - Still keeping this open? > Consider adding join key to

[jira] [Commented] (KAFKA-189) Create a script for dump segment tool

[ https://issues.apache.org/jira/browse/KAFKA-189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583075#comment-15583075 ] Andrew Musselman commented on KAFKA-189: Any interest in this; been open a while. > Create a

[jira] [Commented] (KAFKA-2424) Consider introducing lint-like tool for Scala

[ https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583065#comment-15583065 ] Andrew Musselman commented on KAFKA-2424: - Looks like Abide doesn't have a way to include it in

[jira] [Commented] (KAFKA-2607) Review `Time` interface and its usage

[ https://issues.apache.org/jira/browse/KAFKA-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583043#comment-15583043 ] Andrew Musselman commented on KAFKA-2607: - Looks like the PR has conflicts now; is this still in

[jira] [Commented] (KAFKA-2247) Merge kafka.utils.Time and kafka.common.utils.Time

[ https://issues.apache.org/jira/browse/KAFKA-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583038#comment-15583038 ] Andrew Musselman commented on KAFKA-2247: - [~aauradkar] [~ijuma] Do you have a path to resolve

[jira] [Commented] (KAFKA-3408) consumer rebalance fail

[ https://issues.apache.org/jira/browse/KAFKA-3408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583027#comment-15583027 ] Andrew Musselman commented on KAFKA-3408: - [~sdhzlzhk] Can you provide more repro info? >

[jira] [Commented] (KAFKA-1703) The bat script failed to start on windows

[ https://issues.apache.org/jira/browse/KAFKA-1703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583022#comment-15583022 ] Andrew Musselman commented on KAFKA-1703: - Has this been vetted/merged? > The bat script failed

[jira] [Commented] (KAFKA-1715) better advertising of the bound and working interface

[ https://issues.apache.org/jira/browse/KAFKA-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582992#comment-15582992 ] Andrew Musselman commented on KAFKA-1715: - [~joestein] any more description/guidance, or is this

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583016#comment-15583016 ] Andrew Musselman commented on KAFKA-2200: - Still an issue? > kafkaProducer.send() should not call

[jira] [Commented] (KAFKA-2167) ZkUtils updateEphemeralPath JavaDoc (spelling and correctness)

[ https://issues.apache.org/jira/browse/KAFKA-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15583009#comment-15583009 ] Andrew Musselman commented on KAFKA-2167: - Looks like this ticket should be closed. > ZkUtils

[jira] [Commented] (KAFKA-2602) Incorrect descriptions about serializers for ProducerConfig in 0.8.2 and 0.8.3 documentation

[ https://issues.apache.org/jira/browse/KAFKA-2602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582987#comment-15582987 ] Andrew Musselman commented on KAFKA-2602: - Is this still open/should this patch be applied? >

[jira] [Commented] (KAFKA-2544) Replication tools wiki page needs to be updated

[ https://issues.apache.org/jira/browse/KAFKA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582980#comment-15582980 ] Andrew Musselman commented on KAFKA-2544: - [~gwenshap] do you know who could add Lauren to the

[jira] [Commented] (KAFKA-1351) String.format is very expensive in Scala

[ https://issues.apache.org/jira/browse/KAFKA-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582973#comment-15582973 ] Andrew Musselman commented on KAFKA-1351: - Still open? > String.format is very expensive in Scala

Kafka KIP meeting Oct 19 at 11:00am PST

Hi, Everyone., We plan to have a Kafka KIP meeting this coming Wednesday at 11:00am PST. If you plan to attend but haven't received an invite, please let me know. The following is the tentative agenda. Agenda: KIP-82: add record header Thanks, Jun

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582896#comment-15582896 ] Andrew Musselman commented on KAFKA-4308: - It is; mark this as a dupe? > Inconsistent parameters

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582890#comment-15582890 ] Manasvi Gupta commented on KAFKA-4308: -- I think this one is duplicate of KAFKA-4307 > Inconsistent

[jira] [Work started] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4307 started by Manasvi Gupta. > Inconsistent parameters between console producer and consumer >

[jira] [Assigned] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manasvi Gupta reassigned KAFKA-4307: Assignee: Manasvi Gupta > Inconsistent parameters between console producer and consumer >

[jira] [Commented] (KAFKA-205) Audit swallowing of exceptions/throwables

[ https://issues.apache.org/jira/browse/KAFKA-205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582871#comment-15582871 ] Andrew Musselman commented on KAFKA-205: Still a need for this audit? > Audit swallowing of

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582846#comment-15582846 ] Andrew Musselman commented on KAFKA-4308: - Oh I just meant go ahead, hadn't seen your comment; I

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582838#comment-15582838 ] Umesh Chaudhary commented on KAFKA-4308: Sure Andrew, can you please assign this to me? >

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582824#comment-15582824 ] Andrew Musselman commented on KAFKA-4308: - Ha, Umesh go for it. > Inconsistent parameters between

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582822#comment-15582822 ] Andrew Musselman commented on KAFKA-4308: - I'll do it and make a PR if that's the right workflow.

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582819#comment-15582819 ] Umesh Chaudhary commented on KAFKA-4308: Hi [~gwenshap], I would like to work on this. If

[jira] [Created] (KAFKA-4308) Inconsistent parameters between console producer and consumer

Gwen Shapira created KAFKA-4308: --- Summary: Inconsistent parameters between console producer and consumer Key: KAFKA-4308 URL: https://issues.apache.org/jira/browse/KAFKA-4308 Project: Kafka

[jira] [Created] (KAFKA-4307) Inconsistent parameters between console producer and consumer

Gwen Shapira created KAFKA-4307: --- Summary: Inconsistent parameters between console producer and consumer Key: KAFKA-4307 URL: https://issues.apache.org/jira/browse/KAFKA-4307 Project: Kafka

Re: [VOTE] 0.10.1.0 RC3

+1 (binding) Verified license, notice, signatures, unit tests and ran a bunch of quickstart scenarios. On Sat, Oct 15, 2016 at 12:16 PM, Eno Thereska wrote: > +1 (non-binding) > >> On 15 Oct 2016, at 17:47, Jason Gustafson wrote: >> >> As promised,

[jira] [Created] (KAFKA-4306) Connect workers won't shut down if brokers are not available

Gwen Shapira created KAFKA-4306: --- Summary: Connect workers won't shut down if brokers are not available Key: KAFKA-4306 URL: https://issues.apache.org/jira/browse/KAFKA-4306 Project: Kafka

[jira] [Commented] (KAFKA-4238) consumer-subscription not working, when accessing a newly created topic immediately after its creation with the AdminUtils

[ https://issues.apache.org/jira/browse/KAFKA-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582715#comment-15582715 ] Jason Gustafson commented on KAFKA-4238: We've debated a little bit on the current behavior of

[jira] [Commented] (KAFKA-4238) consumer-subscription not working, when accessing a newly created topic immediately after its creation with the AdminUtils

[ https://issues.apache.org/jira/browse/KAFKA-4238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582593#comment-15582593 ] Florian Witteler commented on KAFKA-4238: - Thanks, [~hachikuji]! This workaround works fine. I'd

[jira] [Commented] (KAFKA-1733) Producer.send will block indeterminately when broker is unavailable.

[ https://issues.apache.org/jira/browse/KAFKA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582565#comment-15582565 ] Dru Panchal commented on KAFKA-1733: As seen in the following file: The fix was made for the 0.9.0

[jira] [Updated] (KAFKA-1733) Producer.send will block indeterminately when broker is unavailable.

[ https://issues.apache.org/jira/browse/KAFKA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dru Panchal updated KAFKA-1733: --- Fix Version/s: 0.8.2.0 > Producer.send will block indeterminately when broker is unavailable. >

[jira] [Updated] (KAFKA-1733) Producer.send will block indeterminately when broker is unavailable.

[ https://issues.apache.org/jira/browse/KAFKA-1733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dru Panchal updated KAFKA-1733: --- Affects Version/s: 0.8.1.1 > Producer.send will block indeterminately when broker is unavailable. >

[jira] [Created] (KAFKA-4305) Possible race condition in log segment truncation and Kafka Request Handler

Hari created KAFKA-4305: --- Summary: Possible race condition in log segment truncation and Kafka Request Handler Key: KAFKA-4305 URL: https://issues.apache.org/jira/browse/KAFKA-4305 Project: Kafka

[jira] [Commented] (KAFKA-3559) Task creation time taking too long in rebalance callback

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

[GitHub] kafka pull request #2032: KAFKA-3559: Recycle old tasks when possible

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2032 KAFKA-3559: Recycle old tasks when possible You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka

[jira] [Closed] (KAFKA-4299) Consumer offsets reset for all topics after increasing partitions for one topic

[ https://issues.apache.org/jira/browse/KAFKA-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio closed KAFKA-4299. - > Consumer offsets reset for all topics after increasing partitions for one > topic >

[jira] [Resolved] (KAFKA-4299) Consumer offsets reset for all topics after increasing partitions for one topic

[ https://issues.apache.org/jira/browse/KAFKA-4299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juho Autio resolved KAFKA-4299. --- Resolution: Cannot Reproduce I did another partition modification in production and this time it

Re: [DISCUSS] KIP-68 Add a consumed log retention before log retention

Hey David, Thanks for replies to the questions. I think one major thing still not clear at this point is that whether the brokers will only apply the consumed log retention to a specific set of interested consumer groups, or it does not have such a set of consumer groups. For example, for topic

Re: [DISCUSS] KIP-82 - Add Record Headers

Hi Jun, Sounds good. Look forward to the invite. Cheers, Mike From: Jun Rao Sent: Monday, October 17, 2016 5:55:57 AM To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-82 - Add Record Headers Hi, Michael, We do have online KIP