> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(ReplicaStateMachine.scala:372)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply(ReplicaStateMachine.scala:359)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1$$anonfun$apply$mcV$sp$1.apply(ReplicaStateMachine.scala:359)
> > > > at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply$mcV$sp(ReplicaStateMachine.scala:358)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply(ReplicaStateMachine.scala:357)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener$$anonfun$handleChildChange$1.apply(ReplicaStateMachine.scala:357)
> > > > at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:231)
> > > > at
> > > >
> > >
> >
> kafka.controller.ReplicaStateMachine$BrokerChangeListener.handleChildChange(ReplicaStateMachine.scala:356)
> > > > at
> > org.I0Itec.zkclient.ZkClient$10.run(ZkClient.java:843)
> > > > at
> > > > org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
> > > >
> > > >
> > >
> > >
> > > --
> > > -- Guozhang
> > >
> >
>
--
Regards
Vamsi Subhash
[
https://issues.apache.org/jira/browse/KAFKA-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15271007#comment-15271007
]
Vamsi Subhash Achanta commented on KAFKA-3657:
--
I haven't tested i
Vamsi Subhash Achanta created KAFKA-3657:
Summary: NewProducer NullPointerException on ProduceRequest
Key: KAFKA-3657
URL: https://issues.apache.org/jira/browse/KAFKA-3657
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-3657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-3657:
-
Description:
The producer upon send.get() on the future appends to the
and documentation improvements.
> >
> > Thank you for your contribution and welcome to Apache Kafka, Ismael!
> >
> > --
> > Thanks,
> > Neha
> >
>
--
Regards
Vamsi Subhash
[
https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15199544#comment-15199544
]
Vamsi Subhash Achanta commented on KAFKA-3359:
--
*bump*
Can this be revi
Can some one please review this?
On Fri, Mar 11, 2016 at 12:09 AM, Achanta Vamsi Subhash <
achanta.va...@flipkart.com> wrote:
> Hi,
> I would like to make this into 0.0.10.0 so can someone look into this and
> review?
>
> On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi S
[
https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-3359:
-
Priority: Major (was: Minor)
> Parallel log-recovery of un-flushed segments
Hi,
I would like to make this into 0.0.10.0 so can someone look into this and
review?
On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi Subhash <
achanta.va...@flipkart.com> wrote:
> Hi all,
>
> https://github.com/apache/kafka/pull/1035
> This pull request will make the log-seg
[
https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-3359:
-
Reviewer: Grant Henke
Fix Version/s: 0.10.0.0
Status: Patch
e current sequential implementation
as the default thread count is set to 1.
JIRA link is here:
https://issues.apache.org/jira/browse/KAFKA-3359
Please review and give me suggestions. Will make them and contribute.
Thanks.
On Wed, Mar 9, 2016 at 7:57 PM, vamsi-subhash wrote:
> GitHub user
[
https://issues.apache.org/jira/browse/KAFKA-3359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-3359:
-
Issue Type: Improvement (was: Bug)
> Parallel log-recovery of un-flus
Vamsi Subhash Achanta created KAFKA-3359:
Summary: Parallel log-recovery of un-flushed segments on startup
Key: KAFKA-3359
URL: https://issues.apache.org/jira/browse/KAFKA-3359
Project: Kafka
GitHub user vamsi-subhash opened a pull request:
https://github.com/apache/kafka/pull/1035
Parallel log-recovery of un-flushed segments on startup
Did not find any tests for the method. Will be adding them
You can merge this pull request into a Git repository by running:
$ git
[
https://issues.apache.org/jira/browse/KAFKA-2163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15185020#comment-15185020
]
Vamsi Subhash Achanta commented on KAFKA-2163:
--
Can this be merged
[
https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15177342#comment-15177342
]
Vamsi Subhash Achanta commented on KAFKA-2967:
--
Emacs org mode works
;
> Guozhang
>
> On Tue, Feb 2, 2016 at 1:37 AM, Achanta Vamsi Subhash <
> achanta.va...@flipkart.com> wrote:
>
> > Hi all,
> >
> > I am going through the partition assignment logic in the Kafka new
> > consumer. Is there any documentation for the l
Hi all,
I am going through the partition assignment logic in the Kafka new
consumer. Is there any documentation for the logic implemented? It would be
great if some one can write the algorithm for consumer partition assignment
(within a group and across groups).
--
Regards
Vamsi Subhash
[
https://issues.apache.org/jira/browse/KAFKA-1229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14557737#comment-14557737
]
Vamsi Subhash Achanta commented on KAFKA-1229:
--
Can this be revisited?
[
https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14549252#comment-14549252
]
Vamsi Subhash Achanta edited comment on KAFKA-1977 at 5/18/15 9:2
[
https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14549252#comment-14549252
]
Vamsi Subhash Achanta commented on KAFKA-1977:
--
Hi Will,
Even I
[
https://issues.apache.org/jira/browse/KAFKA-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14547606#comment-14547606
]
Vamsi Subhash Achanta commented on KAFKA-1977:
--
can this be merged in
[
https://issues.apache.org/jira/browse/KAFKA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14509083#comment-14509083
]
Vamsi Subhash Achanta commented on KAFKA-2134:
--
We noticed
[
https://issues.apache.org/jira/browse/KAFKA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-2134:
-
Priority: Blocker (was: Major)
> Producer blocked on metric publ
[
https://issues.apache.org/jira/browse/KAFKA-2134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-2134:
-
Description:
Hi,
We have a REST api to publish to a topic. Yesterday, we started
Vamsi Subhash Achanta created KAFKA-2134:
Summary: Producer blocked on metric publish
Key: KAFKA-2134
URL: https://issues.apache.org/jira/browse/KAFKA-2134
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-1791:
-
Attachment: 0233.log
Attached the log file.
> Corrupt in
[
https://issues.apache.org/jira/browse/KAFKA-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14221851#comment-14221851
]
Vamsi Subhash Achanta commented on KAFKA-1791:
--
Attached the
[
https://issues.apache.org/jira/browse/KAFKA-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vamsi Subhash Achanta updated KAFKA-1791:
-
Attachment: 0233.index
This was over a period of time when the
[
https://issues.apache.org/jira/browse/KAFKA-1791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14220499#comment-14220499
]
Vamsi Subhash Achanta commented on KAFKA-1791:
--
Its around 40 KB.
>
Vamsi Subhash Achanta created KAFKA-1791:
Summary: Corrupt index after safe shutdown and restart
Key: KAFKA-1791
URL: https://issues.apache.org/jira/browse/KAFKA-1791
Project: Kafka
31 matches
Mail list logo
