[jira] [Commented] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15418751#comment-15418751 ] Manikumar Reddy commented on KAFKA-3959: looks like this is done on purpose. While creating

[jira] [Resolved] (KAFKA-1612) Consumer offsets auto-commit before processing finishes

[ https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1612. Resolution: Won't Fix Closing this issue in favor new consumer API. > Consumer offs

Re: [VOTE] KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change

+1 (non-binding) On Wed, Aug 10, 2016 at 8:30 AM, Ewen Cheslack-Postava wrote: > +1 (binding), thanks for working on this Vahid. > > @Dana - See https://cwiki.apache.org/confluence/display/KAFKA/Bylaws re: > binding/non-binding, although I now notice that we specify criteria

Re: [kafka-clients] [VOTE] 0.10.0.1 RC2

t; details: >> >> http://home.apache.org/~ijuma/kafka-0.10.0.1-rc2/RELEASE_NOTES.html >> >> When compared to RC1, RC2 contains a fix for a regression where an older >> version of slf4j-log4j12 was also being included in the libs folder of the >> binary tarball (KAFKA

Re: [kafka-clients] [VOTE] 0.10.0.1 RC1

Hi, There are two versions of slf4j-log4j jar in the build. (1.6.1, 1.7.21). slf4j-log4j12-1.6.1.jar is coming from streams:examples module. Thanks, Manikumar On Tue, Aug 2, 2016 at 8:31 PM, Ismael Juma <ism...@juma.me.uk> wrote: > Hello Kafka users, developers and client-d

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Affects Version/s: (was: 0.10.0.0) 0.9.0.0 > kafka mirror ma

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Reviewer: Ismael Juma Fix Version/s: 0.10.0.1 > kafka mirror maker t

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- Affects Version/s: 0.10.0.0 > kafka mirror maker tool is not respecting whitelist opt

[jira] [Commented] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15399444#comment-15399444 ] Manikumar Reddy commented on KAFKA-3950: [~ijuma] Can we include this in 0.10.0.1 release

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15393962#comment-15393962 ] Manikumar Reddy commented on KAFKA-3992: looks like you are giving same client-Id (consumerId

[jira] [Comment Edited] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390792#comment-15390792 ] Manikumar Reddy edited comment on KAFKA-3980 at 7/23/16 6:27 PM

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15390792#comment-15390792 ] Manikumar Reddy commented on KAFKA-3980: [~ajorgensen] Can you enable debug log and check Produce

[jira] [Commented] (KAFKA-3980) JmxReporter uses excessive memory causing OutOfMemoryException

[ https://issues.apache.org/jira/browse/KAFKA-3980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15387174#comment-15387174 ] Manikumar Reddy commented on KAFKA-3980: This may due to increasing in client quota metrics

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379198#comment-15379198 ] Manikumar Reddy commented on KAFKA-3102: Subscribe to user mailing list. Details are here: http

[jira] [Updated] (KAFKA-2213) Log cleaner should write compacted messages using configured compression type

[ https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2213: --- Resolution: Duplicate Status: Resolved (was: Patch Available) This duplicate

[jira] [Commented] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15379135#comment-15379135 ] Manikumar Reddy commented on KAFKA-3102: [~liuxinjian] There is no kafka issue. This looks like

[jira] [Resolved] (KAFKA-3102) Kafka server unable to connect to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3102. Resolution: Duplicate > Kafka server unable to connect to zookee

Re: [DISCUSS] KIP-4 ACL Admin Schema

Hi, Can we allow ListAcls to take list of resources? This may help when we have many associated resources under same principal. Thanks Manikumar On Fri, Jul 15, 2016 at 11:15 AM, Gwen Shapira <g...@confluent.io> wrote: > Thank you, Grant. This is lovely :) > > Few comm

[jira] [Commented] (KAFKA-3961) broker sends malformed response when switching from no compression to snappy/gzip

[ https://issues.apache.org/jira/browse/KAFKA-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15375342#comment-15375342 ] Manikumar Reddy commented on KAFKA-3961: you can try DumpLogSegments tools to to verify messages

[jira] [Commented] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15373115#comment-15373115 ] Manikumar Reddy commented on KAFKA-3950: I was also thinking similar lines. Instead of removing

[jira] [Updated] (KAFKA-3950) kafka mirror maker tool is not respecting whitelist option

[ https://issues.apache.org/jira/browse/KAFKA-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3950: --- consumer.subscribe(Pattern p , ..) method is failing when authorizer is enabled. irrespective

consumer.subscribe(Pattern p , ..) method fails with Authorizer

$) org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [__consumer_offsets] Thanks, Manikumar

Re: [VOTE] KIP-4 Create Topics Schema

+1 (non-binding) On Tue, Jun 21, 2016 at 9:16 AM, Ewen Cheslack-Postava wrote: > +1 (binding) and thanks for the work on this Grant! > > -Ewen > > On Mon, Jun 20, 2016 at 12:18 PM, Gwen Shapira wrote: > > > +1 (binding) > > > > On Mon, Jun 20, 2016 at

Re: [VOTE] KIP-62: Allow consumer to send heartbeats from a background thread

+1 (non-binding) On Fri, Jun 17, 2016 at 3:37 PM, Rajini Sivaram < rajinisiva...@googlemail.com> wrote: > +1 (non-binding) > > On Fri, Jun 17, 2016 at 4:45 AM, Grant Henke wrote: > > > +1 > > > > On Thu, Jun 16, 2016 at 8:50 PM, tao xiao wrote: > > >

[jira] [Updated] (KAFKA-3802) log mtimes reset on broker restart

[ https://issues.apache.org/jira/browse/KAFKA-3802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3802: --- Status: Patch Available (was: Open) > log mtimes reset on broker rest

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2651: --- Fix Version/s: 0.11.0.0 > Remove deprecated config alteration from TopicCommand in 0.9.

Re: [VOTE] KIP-58 - Make Log Compaction Point Configurable

+1 (non binding) On Wed, May 25, 2016 at 4:03 PM, Tom Crayford wrote: > +1 (non binding) > > Agree on log.cleaner.compaction.delay.ms being the better name. > > I think this setting is going to be extremely hard to tune for users, and > worry about adding yet more

Re: Apache Kafka JIRA Worflow: Add Closed -> Reopen transition

Hi, There were some jiras which are closed but not resolved. I just wanted to close those jiras properly, so that they won't appear in jira search. Without this new transition i was not able close them properly. Manikumar On May 21, 2016 11:23 AM, "Harsha" <ka...@harsha.io> wro

[jira] [Resolved] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

[ https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2547. Resolution: Fixed > Make DynamicConfigManager to use the ZkNodeChangeNotificationListe

[jira] [Updated] (KAFKA-2547) Make DynamicConfigManager to use the ZkNodeChangeNotificationListener introduced as part of KAFKA-2211

[ https://issues.apache.org/jira/browse/KAFKA-2547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2547: --- Status: Reopened (was: Closed) > Make DynamicConfigManager to

[jira] [Resolved] (KAFKA-3219) Long topic names mess up broker topic state

[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3219. Resolution: Fixed > Long topic names mess up broker topic st

[jira] [Updated] (KAFKA-3219) Long topic names mess up broker topic state

[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3219: --- Status: Reopened (was: Closed) > Long topic names mess up broker topic st

Apache Kafka JIRA Worflow: Add Closed -> Reopen transition

Jun/Ismail, I requested Apache Infra to change JIRA workflow to add Closed -> Reopen transition. https://issues.apache.org/jira/browse/INFRA-11857 Let me know, If any concerns Manikumar

[jira] [Resolved] (KAFKA-2800) Update outdated dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2800. Resolution: Fixed > Update outdated dependenc

[jira] [Updated] (KAFKA-2800) Update outdated dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2800: --- Status: Reopened (was: Closed) > Update outdated dependenc

Re: Perf producer/consumers for compacted topics

kafka.log:type=LogCleanerManager,name=max-dirty-percent Manikumar On Tue, May 17, 2016 at 8:45 PM, Tom Crayford <tcrayf...@heroku.com> wrote: > Hi there, > > As noted in the 0.10.0.0-RC4 release thread, we (Heroku Kafka) have been > doing extensive benchmarking of Kafka. In our ca

[jira] [Updated] (KAFKA-2159) offsets.topic.segment.bytes and offsets.topic.retention.minutes are ignored

[ https://issues.apache.org/jira/browse/KAFKA-2159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2159: --- Resolution: Duplicate Status: Resolved (was: Patch Available

[jira] [Closed] (KAFKA-665) Outgoing responses delayed on a busy Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy closed KAFKA-665. - > Outgoing responses delayed on a busy Kafka bro

[jira] [Resolved] (KAFKA-1201) offset in LogCleaner.awaitCleaned is not enforced

[ https://issues.apache.org/jira/browse/KAFKA-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1201. Resolution: Duplicate Assignee: (was: Jay Kreps) Fix Version/s: 0.9.0.0

[jira] [Assigned] (KAFKA-3389) ReplicaStateMachine areAllReplicasForTopicDeleted check not handling well case when there are no replicas for topic

[ https://issues.apache.org/jira/browse/KAFKA-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3389: -- Assignee: Manikumar Reddy (was: Neha Narkhede) > ReplicaStateMach

[jira] [Commented] (KAFKA-3389) ReplicaStateMachine areAllReplicasForTopicDeleted check not handling well case when there are no replicas for topic

[ https://issues.apache.org/jira/browse/KAFKA-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15282496#comment-15282496 ] Manikumar Reddy commented on KAFKA-3389: Scala map.forall(predicate) returns true for empty map

[jira] [Resolved] (KAFKA-2868) retry.backoff.ms ignored by Producer

[ https://issues.apache.org/jira/browse/KAFKA-2868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2868. Resolution: Duplicate This was fixed in KAFKA-2138 > retry.backoff.ms ignored by Produ

[jira] [Resolved] (KAFKA-3593) kafka.network.Processor throws ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/KAFKA-3593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3593. Resolution: Duplicate > kafka.network.Processor throws ArrayIndexOutOfBoundsExcept

[jira] [Updated] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

[ https://issues.apache.org/jira/browse/KAFKA-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3584: --- Status: Patch Available (was: Open) > NullPointer Exception found when Delete Topic and

[jira] [Commented] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15272275#comment-15272275 ] Manikumar Reddy commented on KAFKA-3525: 1. Assume reserved.broker.max.id =1000 2. Configure

[jira] [Commented] (KAFKA-3147) Memory records is not writable in MirrorMaker

[ https://issues.apache.org/jira/browse/KAFKA-3147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15270385#comment-15270385 ] Manikumar Reddy commented on KAFKA-3147: Similar exception scenario is fixed in KAFKA-3594. Above

[jira] [Updated] (KAFKA-2651) Remove deprecated config alteration from TopicCommand in 0.9.1.0

[ https://issues.apache.org/jira/browse/KAFKA-2651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2651: --- Assignee: Manikumar Reddy Status: Patch Available (was: Open) > Remove depreca

[jira] [Commented] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15261630#comment-15261630 ] Manikumar Reddy commented on KAFKA-3587: [~ecomar] your alternative approach looks good. I haven't

[jira] [Updated] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

[ https://issues.apache.org/jira/browse/KAFKA-3629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3629: --- Status: Patch Available (was: Open) > KStreamImpl.to(...) throws NPE when the value Se

Re: [ANNOUNCE] New committer: Ismael Juma

Congrats Ismael!! On Tue, Apr 26, 2016 at 12:03 PM, Ashish Singh wrote: > Congrats Ismael, well deserved! > > On Monday, April 25, 2016, Guozhang Wang wrote: > > > Congrats Ismael! > > > > On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede

[jira] [Commented] (KAFKA-3609) Implement partial mirroring functionality in Kafka Mirror Maker

[ https://issues.apache.org/jira/browse/KAFKA-3609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253761#comment-15253761 ] Manikumar Reddy commented on KAFKA-3609: Current Mirror Maker supports partial mirroring of topics

[jira] [Updated] (KAFKA-3517) Document configuration of SASL/PLAIN and multiple mechanisms

[ https://issues.apache.org/jira/browse/KAFKA-3517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3517: --- Status: Patch Available (was: Open) > Document configuration of SASL/PLAIN and multi

[jira] [Updated] (KAFKA-3605) Connector REST endpoint allows incorrectly overriding the connector name

[ https://issues.apache.org/jira/browse/KAFKA-3605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3605: --- Status: Patch Available (was: Reopened) > Connector REST endpoint allows incorrec

[jira] [Assigned] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

[ https://issues.apache.org/jira/browse/KAFKA-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3584: -- Assignee: Manikumar Reddy (was: Jay Kreps) > NullPointer Exception found when Del

[jira] [Assigned] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3587: -- Assignee: Manikumar Reddy > LogCleaner fails due to incorrect offset map computat

[jira] [Updated] (KAFKA-3602) Rename RecordAccumulator dequeFor() and ensure proper usage

[ https://issues.apache.org/jira/browse/KAFKA-3602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3602: --- Status: Patch Available (was: Open) > Rename RecordAccumulator dequeFor() and ensure pro

[jira] [Updated] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3594: --- Status: Patch Available (was: Open) > Kafka new producer retries doesn't work in 0.9.

[jira] [Comment Edited] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251692#comment-15251692 ] Manikumar Reddy edited comment on KAFKA-3594 at 4/21/16 10:43 AM: -- Thanks

[jira] [Updated] (KAFKA-3594) Kafka new producer retries doesn't work in 0.9.0.1

[ https://issues.apache.org/jira/browse/KAFKA-3594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3594: --- Assignee: Manikumar Reddy (was: Jun Rao) Priority: Critical (was: Major

[jira] [Resolved] (KAFKA-3572) Metrics of topics still exist when they have been deleted

[ https://issues.apache.org/jira/browse/KAFKA-3572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3572. Resolution: Duplicate This issue is fixed in KAFKA-1866 and similar issue is getting fixed

[jira] [Resolved] (KAFKA-3326) Error: A JNI error has occurred, please check your installation and try again

[ https://issues.apache.org/jira/browse/KAFKA-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3326. Resolution: Not A Problem > Error: A JNI error has occurred, please check your installat

[jira] [Resolved] (KAFKA-2524) Examples in class javadoc use unimplemented subscribe method

[ https://issues.apache.org/jira/browse/KAFKA-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2524. Resolution: Fixed Fix Version/s: 0.10.0.0 > Examples in class javadoc

[jira] [Resolved] (KAFKA-2912) Add error code 4 (InvalidFetchSize) to Errors.java

[ https://issues.apache.org/jira/browse/KAFKA-2912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2912. Resolution: Fixed Assignee: Grant Henke (was: jin xing) Fix Version/s

[jira] [Updated] (KAFKA-3580) improve error logging in ReplicaFetchThread with oversized message

[ https://issues.apache.org/jira/browse/KAFKA-3580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3580: --- Labels: (was: label) Assignee: Manikumar Reddy Status: Patch Available

[jira] [Updated] (KAFKA-2955) Add Prompt to kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-2955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2955: --- Assignee: Manikumar Reddy (was: Jun Rao) Fix Version/s: 0.10.0.0 Status

[jira] [Commented] (KAFKA-3391) Kafka to ZK timeout

[ https://issues.apache.org/jira/browse/KAFKA-3391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15245402#comment-15245402 ] Manikumar Reddy commented on KAFKA-3391: increasing ZK timeout may help. Kafka user mailing list

[jira] [Resolved] (KAFKA-2416) misleading kafka-console-consumer.sh --property option

[ https://issues.apache.org/jira/browse/KAFKA-2416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2416. Resolution: Fixed Assignee: (was: Sreepathi Prasanna) This got fixed in KAFKA

[jira] [Resolved] (KAFKA-2157) kafka-console-consumer.sh: Mismatch in CLI "usage" docs vs. Scala Option parsing

[ https://issues.apache.org/jira/browse/KAFKA-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2157. Resolution: Fixed Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0

[jira] [Resolved] (KAFKA-361) Add ability to get offsets from ZK-based consumer

[ https://issues.apache.org/jira/browse/KAFKA-361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-361. --- Resolution: Fixed > Add ability to get offsets from ZK-based consu

[jira] [Resolved] (KAFKA-364) Consumer re-design

[ https://issues.apache.org/jira/browse/KAFKA-364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-364. --- Resolution: Fixed > Consumer re-design > -- > > Ke

[jira] [Resolved] (KAFKA-360) Add ability to disable rebalancing in ZooKeeper consumer

[ https://issues.apache.org/jira/browse/KAFKA-360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-360. --- Resolution: Fixed > Add ability to disable rebalancing in ZooKeeper consu

[jira] [Resolved] (KAFKA-390) Implement the rebalancing protocol between co-ordinator and consumer

[ https://issues.apache.org/jira/browse/KAFKA-390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-390. --- Resolution: Duplicate > Implement the rebalancing protocol between co-ordinator and consu

[jira] [Resolved] (KAFKA-389) Add a consumer client that connects to the co-ordinator for rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-389. --- Resolution: Duplicate > Add a consumer client that connects to the co-ordina

[jira] [Resolved] (KAFKA-387) Add a centralized co-ordinator for consumer rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-387. --- Resolution: Duplicate > Add a centralized co-ordinator for consumer rebalanc

[jira] [Resolved] (KAFKA-1176) Secure Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1176. Resolution: Fixed Fix Version/s: 0.9.0.0 Many of the security related features

[jira] [Resolved] (KAFKA-3050) Space in the value for "host.name" causes "Unresolved address"

[ https://issues.apache.org/jira/browse/KAFKA-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3050. Resolution: Fixed Fix Version/s: 0.9.0.0 This got fixed in 0.9.0.0 release > Sp

[jira] [Resolved] (KAFKA-3005) delete kafka topic without delete.topic.enable=true

[ https://issues.apache.org/jira/browse/KAFKA-3005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3005. Resolution: Not A Problem Your approach is error prone. Use rolling restart to set

[jira] [Resolved] (KAFKA-1058) Change the patch review tool to use the reviewboard python client

[ https://issues.apache.org/jira/browse/KAFKA-1058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1058. Resolution: Won't Fix Kafka code contribution process is moved to Github PR process

[jira] [Resolved] (KAFKA-119) Avoid duplicated code in ProducerPerformance

[ https://issues.apache.org/jira/browse/KAFKA-119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-119. --- Resolution: Won't Fix ProducerPerformance.scala is deprecated. New ProducerPerformance tool

[jira] [Resolved] (KAFKA-3342) https://cwiki.apache.org/confluence/display/KAFKA/Log+Compaction has log.cleaner.min.cleanable.ratio listed twice in error

[ https://issues.apache.org/jira/browse/KAFKA-3342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3342. Resolution: Fixed Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 Updated

[jira] [Updated] (KAFKA-3406) CommonClientConfigs.RETRY_BACKOFF_MS_DOC should be more general

[ https://issues.apache.org/jira/browse/KAFKA-3406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3406: --- Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 Status: Patch Available

[jira] [Resolved] (KAFKA-2181) online doc issues

[ https://issues.apache.org/jira/browse/KAFKA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2181. Resolution: Fixed Fix Version/s: 0.10.0.0 These minor doc corrections are updated

[jira] [Resolved] (KAFKA-869) Java API needs Encoder / Decoder interfaces

[ https://issues.apache.org/jira/browse/KAFKA-869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-869. --- Resolution: Won't Fix This issue not exists in new java client classes. > Java API ne

[jira] [Resolved] (KAFKA-3067) Fix producer API documentation for case when RequiredAcks > 1

[ https://issues.apache.org/jira/browse/KAFKA-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3067. Resolution: Fixed Assignee: Manikumar Reddy (was: Jun Rao) Fix Version/s

[jira] [Updated] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3525: --- Status: Patch Available (was: Open) > max.reserved.broker.id off-by-one er

[jira] [Commented] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15233241#comment-15233241 ] Manikumar Reddy commented on KAFKA-3525: Yes, by looking this function alone it is possible

[jira] [Assigned] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3525: -- Assignee: Manikumar Reddy > max.reserved.broker.id off-by-one er

[jira] [Resolved] (KAFKA-3372) Trailing space in Kafka ConsumerConfig

[ https://issues.apache.org/jira/browse/KAFKA-3372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3372. Resolution: Fixed Assignee: Manikumar Reddy (was: Neha Narkhede) Fix

[jira] [Resolved] (KAFKA-3516) Metrics settings in server.properties cause ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3516. Resolution: Not A Problem Fix Version/s: 0.10.0.0

[jira] [Assigned] (KAFKA-3516) Metrics settings in server.properties cause ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy reassigned KAFKA-3516: -- Assignee: Manikumar Reddy > Metrics settings in server.properties ca

[jira] [Commented] (KAFKA-3476) -Xloggc is not recognised by IBM java

[ https://issues.apache.org/jira/browse/KAFKA-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15215244#comment-15215244 ] Manikumar Reddy commented on KAFKA-3476: We need to use "-Xverbosegclog" option fo

[jira] [Resolved] (KAFKA-2521) Documentation: Unclear cleanup policy on wiki

[ https://issues.apache.org/jira/browse/KAFKA-2521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2521. Resolution: Fixed This got fixed in KAFKA-2583 > Documentation: Unclear cleanup pol

[jira] [Resolved] (KAFKA-2551) Unclean leader election docs outdated

[ https://issues.apache.org/jira/browse/KAFKA-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2551. Resolution: Fixed > Unclean leader election docs outda

[jira] [Updated] (KAFKA-2551) Unclean leader election docs outdated

[ https://issues.apache.org/jira/browse/KAFKA-2551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-2551: --- Assignee: Manikumar Reddy (was: jin xing) Fix Version/s: 0.10.0.0 GitHub user

[jira] [Comment Edited] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179373#comment-15179373 ] Manikumar Reddy edited comment on KAFKA-3252 at 3/4/16 5:45 AM

[jira] [Commented] (KAFKA-3252) compression type for a topic should be used during log compaction

[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15179373#comment-15179373 ] Manikumar Reddy commented on KAFKA-3252: @ [~singhashish], [~junrao] This issue is related

[jira] [Resolved] (KAFKA-2315) Kafka binary distribution may contain incorrect dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2315. Resolution: Fixed Fix Version/s: 0.9.0.1 This got fixed in 0.9 release. > Ka

Re: [DISCUSS] Deprecating the old Scala producers for the next release

+1 It will be great If we can completely close below issue. https://issues.apache.org/jira/browse/KAFKA-1843 On Tue, Feb 23, 2016 at 3:25 AM, Joel Koshy wrote: > +1 > > Thanks for bringing it up > > On Mon, Feb 22, 2016 at 9:36 AM, Ismael Juma wrote:

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15137191#comment-15137191 ] Manikumar Reddy commented on KAFKA-3218: Thanks for reporting this. Can we add a new configuration

[jira] [Commented] (KAFKA-3017) hostnames with underscores '_' are not valid

[ https://issues.apache.org/jira/browse/KAFKA-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15065227#comment-15065227 ] Manikumar Reddy commented on KAFKA-3017: The Internet standards (Requests for Comments

<    6   7   8   9   10   11   12   13   14   15   >