[
https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15007139#comment-15007139
]
Ashish K Singh commented on KAFKA-2746:
---
[~junrao], [~ijuma] PR is up at
Ashish K Singh created KAFKA-2846:
-
Summary: Add Ducktape test for kafka-consumer-groups
Key: KAFKA-2846
URL: https://issues.apache.org/jira/browse/KAFKA-2846
Project: Kafka
Issue Type: Test
[
https://issues.apache.org/jira/browse/KAFKA-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002821#comment-15002821
]
Ashish K Singh commented on KAFKA-2822:
---
Sounds OK to me.
> DescribeConsumerGroup now returns empty
[
https://issues.apache.org/jira/browse/KAFKA-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15003051#comment-15003051
]
Ashish K Singh commented on KAFKA-2823:
---
[~ijuma], I am working on that. This was mostly to see if
Ashish K Singh created KAFKA-2823:
-
Summary: Kafka fails to start with security.inter.broker.protocol
set to SSL
Key: KAFKA-2823
URL: https://issues.apache.org/jira/browse/KAFKA-2823
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15002740#comment-15002740
]
Ashish K Singh commented on KAFKA-2822:
---
[~hachikuji] I am guessing this was an intended change,
[
https://issues.apache.org/jira/browse/KAFKA-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh resolved KAFKA-2823.
---
Resolution: Not A Problem
This turned out due to wrong configuration of truststore. A better
Ashish K Singh created KAFKA-2822:
-
Summary: DescribeConsumerGroup now returns empty list for
non-existent group, it used to throw IllegalArgumentException
Key: KAFKA-2822
URL:
Ashish K Singh created KAFKA-2768:
-
Summary: New-consumer sends invalid describeGroupResponse while
restabilizing
Key: KAFKA-2768
URL: https://issues.apache.org/jira/browse/KAFKA-2768
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2761:
--
Status: Patch Available (was: In Progress)
> Enable passing regex via whitelist for
[
https://issues.apache.org/jira/browse/KAFKA-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14994335#comment-14994335
]
Ashish K Singh commented on KAFKA-2761:
---
Created PR, https://github.com/apache/kafka/pull/445
>
[
https://issues.apache.org/jira/browse/KAFKA-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2761 started by Ashish K Singh.
-
> Enable passing regex via whitelist for new-consumer in ConsoleConsumer
>
[
https://issues.apache.org/jira/browse/KAFKA-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14992363#comment-14992363
]
Ashish K Singh commented on KAFKA-2077:
---
Hey guys, this seems to be interesting. Is anyone,
Ashish K Singh created KAFKA-2760:
-
Summary: Clean up interface of
AdminClient..describeConsumerGroup(groupId)
Key: KAFKA-2760
URL: https://issues.apache.org/jira/browse/KAFKA-2760
Project: Kafka
Ashish K Singh created KAFKA-2761:
-
Summary: Enable passing regex via whitelist for new-consumer in
ConsoleConsumer
Key: KAFKA-2761
URL: https://issues.apache.org/jira/browse/KAFKA-2761
Project:
[
https://issues.apache.org/jira/browse/KAFKA-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2760:
--
Summary: Clean up interface of AdminClient.describeConsumerGroup(groupId
(was: Clean up
[
https://issues.apache.org/jira/browse/KAFKA-2760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2760:
--
Summary: Clean up interface of AdminClient..describeConsumerGroup(groupId
(was: Clean up
[
https://issues.apache.org/jira/browse/KAFKA-2746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14990363#comment-14990363
]
Ashish K Singh commented on KAFKA-2746:
---
[~hachikuji], [~guozhang], based on discussion with
Ashish K Singh created KAFKA-2734:
-
Summary: kafka-console-consumer throws NoSuchElementException on
not specifying topic
Key: KAFKA-2734
URL: https://issues.apache.org/jira/browse/KAFKA-2734
[
https://issues.apache.org/jira/browse/KAFKA-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14985750#comment-14985750
]
Ashish K Singh commented on KAFKA-2716:
---
[~ijuma], [~gwenshap] I agree that not breaking existing
[
https://issues.apache.org/jira/browse/KAFKA-2716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14983702#comment-14983702
]
Ashish K Singh commented on KAFKA-2716:
---
[~ijuma] lets keep the discussion here, so that it is not
Ashish K Singh created KAFKA-2716:
-
Summary: Make Kafka core not depend on log4j-appender
Key: KAFKA-2716
URL: https://issues.apache.org/jira/browse/KAFKA-2716
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14967999#comment-14967999
]
Ashish K Singh commented on KAFKA-2671:
---
[~gwenshap], [~guozhang] I have updated the patch, could
[
https://issues.apache.org/jira/browse/KAFKA-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14965456#comment-14965456
]
Ashish K Singh commented on KAFKA-2671:
---
[~gwenshap] and [~jkreps] as long as there is an easy way
[
https://issues.apache.org/jira/browse/KAFKA-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964017#comment-14964017
]
Ashish K Singh commented on KAFKA-2671:
---
[~gwenshap], yes it is doable, however one would have to
Ashish K Singh created KAFKA-2671:
-
Summary: Enable starting Kafka server with a Properties object
Key: KAFKA-2671
URL: https://issues.apache.org/jira/browse/KAFKA-2671
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964297#comment-14964297
]
Ashish K Singh commented on KAFKA-2671:
---
Correct me if I am wrong, but below are the options one has
[
https://issues.apache.org/jira/browse/KAFKA-2671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14964345#comment-14964345
]
Ashish K Singh commented on KAFKA-2671:
---
bq. What's the use-case for starting Kafka server as a
[
https://issues.apache.org/jira/browse/KAFKA-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14959684#comment-14959684
]
Ashish K Singh commented on KAFKA-2447:
---
[~gwenshap], I just updated KAFKA-2574 with ducktape based
[
https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14957626#comment-14957626
]
Ashish K Singh commented on KAFKA-2629:
---
[~junrao] [~gwenshap] what do you guys think. As [~yoderme]
[
https://issues.apache.org/jira/browse/KAFKA-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14958100#comment-14958100
]
Ashish K Singh commented on KAFKA-2017:
---
I agree with [~guozhang] that if we are not expecting group
[
https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14958020#comment-14958020
]
Ashish K Singh commented on KAFKA-2629:
---
[~gwenshap] sure. We can pick this up once 0.9.0.0 has been
[
https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14958025#comment-14958025
]
Ashish K Singh commented on KAFKA-2629:
---
[~sriharsha] I am proposing this as an optional config
Ashish K Singh created KAFKA-2630:
-
Summary: Add Namespaces to Kafka
Key: KAFKA-2630
URL: https://issues.apache.org/jira/browse/KAFKA-2630
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14951200#comment-14951200
]
Ashish K Singh commented on KAFKA-2629:
---
Thanks for your thoughts [~sriharsha]. I think you raised
[
https://issues.apache.org/jira/browse/KAFKA-2629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14950873#comment-14950873
]
Ashish K Singh commented on KAFKA-2629:
---
[~junrao], [~gwenshap], [~sriharsha] thoughts?
> Enable
Ashish K Singh created KAFKA-2629:
-
Summary: Enable getting SSL password from an executable rather
than passing plaintext password
Key: KAFKA-2629
URL: https://issues.apache.org/jira/browse/KAFKA-2629
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14907021#comment-14907021
]
Ashish K Singh commented on KAFKA-2573:
---
OK, I have updated the PR to just make the test fail
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905020#comment-14905020
]
Ashish K Singh commented on KAFKA-2573:
---
[~ijuma] thanks for pointing it out. I was under impression
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2573:
--
Status: Patch Available (was: Open)
> Mirror maker system test hangs and eventually fails
>
[
https://issues.apache.org/jira/browse/KAFKA-2531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2531:
--
Description: Add ducktape based tests for KafkaLog4jAppender. (was:
KAFKA-2447 adds support to
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905391#comment-14905391
]
Ashish K Singh commented on KAFKA-2573:
---
I think the test is failing due to a reason it is not
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905194#comment-14905194
]
Ashish K Singh commented on KAFKA-2573:
---
In my PR I removed {{consumer.wait()}} that gets blocked
[
https://issues.apache.org/jira/browse/KAFKA-2573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14905234#comment-14905234
]
Ashish K Singh commented on KAFKA-2573:
---
[~granders] +1 on your suggested change, will incorporate
Ashish K Singh created KAFKA-2573:
-
Summary: Mirror maker system test hangs and eventually fails
Key: KAFKA-2573
URL: https://issues.apache.org/jira/browse/KAFKA-2573
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14903655#comment-14903655
]
Ashish K Singh commented on KAFKA-2571:
---
PR: https://github.com/apache/kafka/pull/231
>
Ashish K Singh created KAFKA-2571:
-
Summary: KafkaLog4jAppender dies while specifying "acks" config
Key: KAFKA-2571
URL: https://issues.apache.org/jira/browse/KAFKA-2571
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2571:
--
Description:
KafkaLog4jAppender specifies "acks" config's value as int, however
KafkaProducer
[
https://issues.apache.org/jira/browse/KAFKA-2571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2571:
--
Status: Patch Available (was: Open)
> KafkaLog4jAppender dies while specifying "acks" config
>
[
https://issues.apache.org/jira/browse/KAFKA-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14901562#comment-14901562
]
Ashish K Singh commented on KAFKA-2003:
---
[~granders] sure!
> Add upgrade tests
> -
[
https://issues.apache.org/jira/browse/KAFKA-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14739128#comment-14739128
]
Ashish K Singh commented on KAFKA-2447:
---
[~gwenshap] perfectly makes sense! Created KAFKA-2531.
>
Ashish K Singh created KAFKA-2533:
-
Summary: Create a member Metadata.Listener inside KafkaConsumer
Key: KAFKA-2533
URL: https://issues.apache.org/jira/browse/KAFKA-2533
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14737744#comment-14737744
]
Ashish K Singh commented on KAFKA-2447:
---
[~gwenshap] agreed! I have tried this on a cluster with
[
https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh resolved KAFKA-2513.
---
Resolution: Won't Fix
> Checkstyle is not executed until gradle's tests phase
>
[
https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14731262#comment-14731262
]
Ashish K Singh commented on KAFKA-2513:
---
I was suggesting this as nice to have. However, if you have
[
https://issues.apache.org/jira/browse/KAFKA-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh resolved KAFKA-2506.
---
Resolution: Duplicate
> Refactor KafkaConsumer.partitionsFor(topic) to get metadata of topic
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729555#comment-14729555
]
Ashish K Singh commented on KAFKA-2461:
---
Should I keep the detailed info in debug level as well? I
[
https://issues.apache.org/jira/browse/KAFKA-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729502#comment-14729502
]
Ashish K Singh commented on KAFKA-2506:
---
I think KAFKA-1893 does not depend on this, we can wait.
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729534#comment-14729534
]
Ashish K Singh commented on KAFKA-2461:
---
[~ijuma] Oops, I got it reversed. That's my bad. However, I
Ashish K Singh created KAFKA-2513:
-
Summary: Checkstyle is not executed until gradle's tests phase
Key: KAFKA-2513
URL: https://issues.apache.org/jira/browse/KAFKA-2513
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729711#comment-14729711
]
Ashish K Singh commented on KAFKA-2461:
---
[~gwenshap], [~ijuma], created
[
https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729740#comment-14729740
]
Ashish K Singh commented on KAFKA-2513:
---
[~ijuma], [~gwenshap] thoughts?
> Checkstyle is not
[
https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14729897#comment-14729897
]
Ashish K Singh commented on KAFKA-2513:
---
I think if one wants to just compile, they can just choose
Ashish K Singh created KAFKA-2505:
-
Summary: Add trace/debug description modes to the new
Request/Response API
Key: KAFKA-2505
URL: https://issues.apache.org/jira/browse/KAFKA-2505
Project: Kafka
Ashish K Singh created KAFKA-2506:
-
Summary: Refactor KafkaConsumer.partitionsFor(topic) to get
metadata of topic without modifying state of Metadata
Key: KAFKA-2506
URL:
[
https://issues.apache.org/jira/browse/KAFKA-2505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2505:
--
Description: It was pointed out on KAFKA-2461 that trace/debug description
modes are required
[
https://issues.apache.org/jira/browse/KAFKA-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14728503#comment-14728503
]
Ashish K Singh commented on KAFKA-2447:
---
[~gwenshap] I think it will be nice to have this in 0.8.3.
[
https://issues.apache.org/jira/browse/KAFKA-2490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh reassigned KAFKA-2490:
-
Assignee: Ashish K Singh
> support new consumer in ConsumerOffsetChecker
>
[
https://issues.apache.org/jira/browse/KAFKA-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh reassigned KAFKA-2487:
-
Assignee: Ashish K Singh
change kafka.examples.Consumer to use the new java consumer
[
https://issues.apache.org/jira/browse/KAFKA-2447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2447:
--
Status: Patch Available (was: Open)
Add capability to KafkaLog4jAppender to be able to use
[
https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14720307#comment-14720307
]
Ashish K Singh commented on KAFKA-2470:
---
I do not think that is an issue as it only
[
https://issues.apache.org/jira/browse/KAFKA-1912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718092#comment-14718092
]
Ashish K Singh commented on KAFKA-1912:
---
[~jkreps], [~guozhang] are we still
[
https://issues.apache.org/jira/browse/KAFKA-2471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718087#comment-14718087
]
Ashish K Singh commented on KAFKA-2471:
---
Could you attach server.log
Replicas
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2461:
--
Status: Patch Available (was: Open)
request logger no longer logs extra information in debug
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712413#comment-14712413
]
Ashish K Singh commented on KAFKA-2468:
---
[~guozhang] could you review and help with
[
https://issues.apache.org/jira/browse/KAFKA-2466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14710804#comment-14710804
]
Ashish K Singh commented on KAFKA-2466:
---
OK, thanks for taking care of it.
Ashish K Singh created KAFKA-2468:
-
Summary: SIGINT during Kafka server startup can leave server
deadlocked
Key: KAFKA-2468
URL: https://issues.apache.org/jira/browse/KAFKA-2468
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712225#comment-14712225
]
Ashish K Singh edited comment on KAFKA-2468 at 8/26/15 12:13 AM:
[
https://issues.apache.org/jira/browse/KAFKA-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14712225#comment-14712225
]
Ashish K Singh commented on KAFKA-2468:
---
[~ewencp] unlike exit(), halt() forcibly
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14709853#comment-14709853
]
Ashish K Singh commented on KAFKA-2461:
---
[~gwenshap] I too noticed this. Do you mind
[
https://issues.apache.org/jira/browse/KAFKA-2461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh reassigned KAFKA-2461:
-
Assignee: Ashish K Singh
request logger no longer logs extra information in debug mode
Ashish K Singh created KAFKA-2466:
-
Summary: ConsoleConsumer throws ConcurrentModificationException on
termination
Key: KAFKA-2466
URL: https://issues.apache.org/jira/browse/KAFKA-2466
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14708507#comment-14708507
]
Ashish K Singh commented on KAFKA-1566:
---
I think it makes sense. Code changes also
Ashish K Singh created KAFKA-2447:
-
Summary: Add capability to KafkaLog4jAppender to be able to use SSL
Key: KAFKA-2447
URL: https://issues.apache.org/jira/browse/KAFKA-2447
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-1893 started by Ashish K Singh.
-
Allow regex subscriptions in the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-1893:
--
Status: Patch Available (was: In Progress)
Allow regex subscriptions in the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694190#comment-14694190
]
Ashish K Singh commented on KAFKA-313:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-313:
-
Attachment: KAFKA-313_2015-08-12_14:21:32.patch
Add JSON/CSV output and looping options to
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-313:
-
Status: Patch Available (was: In Progress)
Add JSON/CSV output and looping options to
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-313:
-
Attachment: KAFKA-313_2015-08-10_12:58:38.patch
Add JSON/CSV output and looping options to
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14680671#comment-14680671
]
Ashish K Singh commented on KAFKA-313:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661294#comment-14661294
]
Ashish K Singh commented on KAFKA-2413:
---
Hi [~onurkaraman], sorry for not explicitly
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661329#comment-14661329
]
Ashish K Singh commented on KAFKA-2413:
---
I am not sure if posting patches to issues
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661094#comment-14661094
]
Ashish K Singh commented on KAFKA-2413:
---
[~hachikuji] thoughts?
New consumer's
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661157#comment-14661157
]
Ashish K Singh commented on KAFKA-2413:
---
Thanks guys for quick response!
Below is a
[
https://issues.apache.org/jira/browse/KAFKA-2413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14661177#comment-14661177
]
Ashish K Singh commented on KAFKA-2413:
---
[~hachikuji] I was planning to play with it
Ashish K Singh created KAFKA-2413:
-
Summary: New consumer's subscribe(Topic...) api fails if called
more than once
Key: KAFKA-2413
URL: https://issues.apache.org/jira/browse/KAFKA-2413
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14660584#comment-14660584
]
Ashish K Singh commented on KAFKA-1893:
---
Should we support topic and regex
[
https://issues.apache.org/jira/browse/KAFKA-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14658944#comment-14658944
]
Ashish K Singh commented on KAFKA-2406:
---
Makes sense. Can I suggest that we still
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14659065#comment-14659065
]
Ashish K Singh commented on KAFKA-1690:
---
[~harsha_ch] sure, no issues. Also, do we
201 - 300 of 512 matches
Mail list logo
