Re: KIP creation permissions
Thank Manikumar for telling me. Yes, I saw that, many functionalities have been included in the kafka-console-consumer.sh. Have a good evening! Best Regards, Daniele Ascione Il giorno mer 23 gen 2019 alle ore 15:45 Manikumar < manikumar.re...@gmail.com> ha scritto: > Done. Thanks for your interest. > > BTW, kafka-simple-consumer-shell was deprecated and removed in 2.0 release. > > On Wed, Jan 23, 2019 at 8:01 PM Daniele Ascione > wrote: > > > Hello Kafka Team, > > > > I would like to have the permissions to create a KIP. I would like to > > propose a feature for the kafka-simple-consumer-shell . > > > > - username: ascione.d > > - Full Name: Daniele Ascione > > - Email: ascion...@gmail.com > > >
KIP creation permissions
Hello Kafka Team, I would like to have the permissions to create a KIP. I would like to propose a feature for the kafka-simple-consumer-shell . - username: ascione.d - Full Name: Daniele Ascione - Email: ascion...@gmail.com
[jira] [Created] (KAFKA-7794) kafka.tools.GetOffsetShell does not return the offset in some cases
Daniele Ascione created KAFKA-7794:
--
Summary: kafka.tools.GetOffsetShell does not return the offset in
some cases
Key: KAFKA-7794
URL: https://issues.apache.org/jira/browse/KAFKA-7794
Project: Kafka
Issue Type: Bug
Components: tools
Affects Versions: 0.10.2.2, 0.10.2.1, 0.10.2.0
Reporter: Daniele Ascione
For some input for the timestamps (different from -1 or -2) the GetOffset is
not able to retrieve the offset.
For example, if _x_ is the timestamp in that "not working range", and you
execute:
{code:java}
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $KAFKA_ADDRESS
--topic $MY_TOPIC--time x
{code}
The output is:
{code:java}
MY_TOPIC:8:
MY_TOPIC:2:
MY_TOPIC:5:
MY_TOPIC:4:
MY_TOPIC:7:
MY_TOPIC:1:
MY_TOPIC:9:{code}
while after the last ":" an integer representing the offset is expected.
Steps to reproduce it:
# Consume all the messages from the beginning with the timestamp:
{code:java}
bin/kafka-simple-consumer-shell.sh --no-wait-at-logend --broker-list
$KAFKA_ADDRESS --topic $MY_TOPIC --property print.timestamp=true >
messages{code}
# Sort the messages by timestamp and get some of the oldest messages:
{code:java}
awk -F "CreateTime:" '{ print $2}' messages > msg_sorted{code}
# Take (for example) the timestamp of the 10th oldest message, and see if
GetOffsetShell is not able to print the offset:
{code:java}
timestamp="$(sed '10q;d' invals.ts.sorted.txt | cut -f1)"
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list $KAFKA_ADDRESS
--topic $MY_TOPIC--time $timestamp
# The output should be something like:
# MY_TOPIC:1:
# MY_TOPIC:2:
(repeated for every partition){code}
# Verify that the message with that timestamp is still in Kafka:
{code:java}
bin/kafka-simple-consumer-shell.sh --no-wait-at-logend --broker-list
$KAFKA_ADDRESS --topic $MY_TOPIC --property print.timestamp=true | grep
"CreateTime:$timestamp" {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
Re: [VOTE] KIP-374: Add '--help' option to all available Kafka CLI commands
+1 (non-binding) Il ven 9 nov 2018, 02:09 Colin McCabe ha scritto: > +1 (binding) > > > > On Wed, Oct 31, 2018, at 05:42, Srinivas Reddy wrote: > > Hi All, > > > > I would like to call for a vote on KIP-374: > > https://cwiki.apache.org/confluence/x/FgSQBQ > > > > Summary: > > Currently, the '--help' option is recognized by some Kafka commands > > but not all. To provide a consistent user experience, it would > > be nice to> add a '--help' option to all Kafka commands. > > > > I'd appreciate any votes or feedback. > > > > -- > > Srinivas Reddy > > > > http://mrsrinivas.com/ > > > > > > (Sent via gmail web) > >
Re: [VOTE] KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.
+1 Thanks, Daniele Il giorno mar 3 lug 2018 alle ore 23:55 Harsha ha scritto: > +1. > > Thanks, > Harsha > > On Tue, Jul 3rd, 2018 at 9:22 AM, Ted Yu wrote: > > > > > > > > > +1 > > > > On Tue, Jul 3, 2018 at 9:05 AM, Mickael Maison < > mickael.mai...@gmail.com > > > > > wrote: > > > > > +1 (non binding) > > > Thanks for the KIP > > > > > > On Tue, Jul 3, 2018 at 4:59 PM, Vahid S Hashemian > > > < vahidhashem...@us.ibm.com > wrote: > > > > +1 (non-binding) > > > > > > > > --Vahid > > > > > > > > > > > > > > > > From: Gwen Shapira < g...@confluent.io > > > > > To: dev < dev@kafka.apache.org > > > > > Date: 07/03/2018 08:49 AM > > > > Subject: Re: [VOTE] KIP-322: Return new error code for > > > DeleteTopics > > > > API when topic deletion disabled. > > > > > > > > > > > > > > > > +1 > > > > > > > > On Tue, Jul 3, 2018 at 8:24 AM, Manikumar < > manikumar.re...@gmail.com > > > > > > > wrote: > > > > > > > >> Manikumar < manikumar.re...@gmail.com > > > > >> Fri, Jun 29, 7:59 PM (4 days ago) > > > >> to dev > > > >> Hi All, > > > >> > > > >> I would like to start voting on KIP-322 which would return new error > > > > code > > > >> for DeleteTopics API when topic deletion disabled. > > > >> > > > >> > > > > https://cwiki.apache.org/confluence/pages/viewpage. > > > action?pageId=87295558 > > > > > > > >> > > > >> Thanks, > > > >> > > > > > > > > > > > > > > > > -- > > > > *Gwen Shapira* > > > > Product Manager | Confluent > > > > 650.450.2760 | @gwenshap > > > > Follow us: Twitter < > > > > https://twitter.com/ConfluentInc > > > >> | blog > > > > < > > > > http://www.confluent.io/blog > > > >> > > > > > > > > > > > > > > > > > > > > > > > > > > >
Re: Please, add me to the committers!
Hello Matthias, thank you very much the informaton and for making me welcome in Apache Kafka community. I look forward to contribute! Kind Regards, Daniele Ascione Il giorno ven 29 giu 2018 alle ore 19:31 Matthias J. Sax < matth...@confluent.io> ha scritto: > Daniele, > > thanks for your interest in working on Kafka! Being a committer has a > very special meaning in the Apache world: > > - https://www.apache.org/dev/committers.html > - https://cwiki.apache.org/confluence/display/KAFKA/Bylaws > > Thus, when you start to work on Kafka, you are a contributor. You should > check out > https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes > to get started. > > Welcome to the Kafka community! > > > -Matthias > > On 6/29/18 7:32 AM, Daniele Ascione wrote: > > Hello guys, > > > > I would be glad to help the project! > > Can I be added as commiter? > > > > Kind Regards, > > Daniele Ascione > > > >
Please, add me to the committers!
Hello guys, I would be glad to help the project! Can I be added as commiter? Kind Regards, Daniele Ascione
