; https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> 119%3A+Drop+Support+for+Scala+2.10+in+Kafka+0.11
>
> Please take a look. Your feedback is appreciated.
>
> Thanks,
> Ismael
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
d when the
> > next major release will happen, but we know that it won't happen before
> > June 2017.
> >
> > Please take a look at the proposal and share your feedback.
> >
> > Thanks,
> > Ismael
> >
> > [1] http://search-hadoop.com/m/Kafka/uyzND1oIhV61GS5Sf2
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
; >
> > Jun
> >
> > On Wed, Jan 11, 2017 at 2:51 PM, Gwen Shapira <g...@confluent.io> wrote:
> >
> > > The PMC for Apache Kafka has invited Grant Henke to join as a
> > > committer and we are pleased to announce that he has accepted!
> > >
&
> > unclean.leader.election.enabled from true to false.
> > >
> > > https://cwiki.apache.org/confluence/display/KAFKA/%
> > > 5BWIP%5D+KIP-106+-+Change+Default+unclean.leader.
> > > election.enabled+from+True+to+False
> > >
> > > B
> > >
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
en Repo.
>
> Thank you in advance!
>
> Best regards
>
> KIM
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
t; > number
> > > > of
> > > > > users may still be using Java 7 by the time Kafka 0.10.1.0 is
> > released.
> > > > > More specifically, we care about the subset who would be able to
> > > upgrade
> > > > to
> > > > > Kafka 0.10.1.0, but would not be able to upgrade the Java version.
> It
> > > > would
> > > > > be great if we could quantify this in some way.
> > > > >
> > > > > What do you think?
> > > > >
> > > > > Ismael
> > > > >
> > > > > [1] https://java.com/en/download/faq/java_7.xml
> > > > > [2]
> > https://blogs.oracle.com/thejavatutorials/entry/jdk_8_is_released
> > > > > [3] http://openjdk.java.net/projects/jdk9/
> > > > > [4] https://github.com/apache/cassandra/blob/trunk/README.asc
> > > > > [5]
> > > https://lucene.apache.org/#highlights-of-this-lucene-release-include
> > > > > [6] http://akka.io/news/2015/09/30/akka-2.4.0-released.html
> > > > > [7] https://issues.apache.org/jira/browse/HADOOP-11858
> > > > > [8] https://webtide.com/jetty-9-3-features/
> > > > > [9] http://markmail.org/message/l7s276y3xkga2eqf
> > > > > [10]
> > > > >
> > > > >
> > > >
> > >
> >
> https://intellij-support.jetbrains.com/hc/en-us/articles/206544879-Selecting-the-JDK-version-the-IDE-will-run-under
> > > > > [11] http://markmail.org/message/l7s276y3xkga2eqf
> > > > >
> > > >
> > >
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
nline so we are completely stuck.
> Any suggestions would be appreciated.
> Thanks,
> Jason
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
.apache.kafka.common.protocol.ProtoUtils.parseRequest(ProtoUtils.java:60)
> at
>
> org.apache.kafka.common.requests.ListOffsetRequest.parse(ListOffsetRequest.java:142)
> at
>
> org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:46)
> at
> kafka.network.RequestChan
tiychuk,
> Dong Lin, Dongjoon Hyun, Drausin Wulsin, Duncan Sands, Dustin Cote,
> Eamon Zhang, edoardo, Edward Ribeiro, Eno Thereska, Ewen
> Cheslack-Postava, Flavio Junqueira, Francois Visconte, Frank Scholten,
> Gabriel Zhang, gaob13, Geoff Anderson, glikson, Grant Henke, Greg
> Fodor, Guoz
se be candid about what’s working and what needs to be improved—this
> community is greater than the sum of its parts, and your responses will
> ultimately help to steer the development of Kafka moving forward.
>
> I will share the results of the survey for everyone to look at.
>
&g
help me or send me the some additional documentation?
> > >
> > > Heath Ivie
> > > Solutions Architect
> > >
> > >
> > > Warning: This e-mail may contain information proprietary to
> AutoAnything
> > > Inc. and is intended only for the use of the intended recipient(s). If
> > the
> > > reader of this message is not the intended recipient(s), you have
> > received
> > > this message in error and any review, dissemination, distribution or
> > > copying of this message is strictly prohibited. If you have received
> this
> > > message in error, please notify the sender immediately and delete all
> > > copies.
> > >
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
> As a client library developer (https://github.com/oleksiyk/kafka) I would
> like to know if its an error in documentation or in Kafka server?
>
> Thanks!
>
> --
> Oleksiy Krivoshey
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
his discussion on the web visit
> >
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G8VbhZ5Q0nVnUAg8qR0yEO%3DqhYrHFtLySpJo1Nha%3DoOxA%40mail.gmail.com
> > <
> https://groups.google.com/d/msgid/kafka-clients/CAFc58G8VbhZ5Q0nVnUAg8qR0yEO%3DqhYrHFtLySpJo1Nha%3DoOxA%40mail.gmail.com?utm_medium=email_source=footer
> >
> > .
> > For more options, visit https://groups.google.com/d/optout.
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
llowing:-
> > >
> > >
> > >1. Is it possible to specify maximum length of a particular topic (
> in
> > >terms of number of messages ) in kafka ?
> > >2. Also how does Kafka behave when a particular topic gets full?
> > >3. Can t
; > maven repository so I can include new api in my dependencies. When the
> > release is officially out, I can have both my code ready with the
> official
> > maven dependency
> >
> > Thanks,
> > Siyuan
> >
> > On Monday, November 16, 2015, Grant H
gt; > The actual thing I want to do is I want to build and install in my
> local
> > > maven repository so I can include new api in my dependencies. When the
> > > release is officially out, I can have both my code ready with the
> > official
> > > maven depen
gt; consumerConnector = ConsumerConfig
>
> .createJavaConsumerConnector(consumerConfig);
>
> Do I have to rewrite the whole consumer to use the new jar. Whats the best
> way forward please?
>
> Regards
>
> Surender Kudumula
>
>
>
--
Grant Henke
Software Engineer | Clouder
ngCodeChanges-PullRequest
> > >
> > > I have one doubt though. Which repo shall I configure as the remote -
> > > apache-kafka or my fork ?
> > >
> > > If I configure apache-kafka as remote, will I be able to submit pull
> > > requests?
> > >
;
> > I got a build error on both trunk and 0.9.0 branch
> >
> > > docs/producer_config.html (No such file or directory)
> >
> > Do I miss anything before build
> >
> > Thanks,
> > Siyuan
> >
>
>
>
> --
> -- Guozhang
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
to upgrade our brokers to 0.9, will
> they accept producers in 0.8.2?
>
> Thanks!
>
> --
> *JU Han*
>
> Software Engineer @ Teads.tv
>
> +33 061960
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
d data transportation services.
>
>
> Many thanks,
>
>
> Scott Krueger
>
>
> Data Architect
>
> skyscanner
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
> >> coordinate for this version? I am asking this because it has
> >> KafkaConsumer api which doesn't exist in 0.8.2
> >>
> >> Thank you
> >>
> >
> >
> >
> > --
> > Thanks,
> > Ewen
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
an Francisco office. We're working on building the
> >> agenda now. Does anyone want to talk? Please send me (and Clark) a
> >> private email with a short description of what you would be talking
> about
> >> if interested.
> >>
> >> --
> >> Thanks,
> >>
> >> Ed Yakabosky
> >> Technical Program Management @ LinkedIn>
> >>
> >>
> >
> > --
> > Thanks,
> > Ed Yakabosky
> >
>
>
>
> --
> Thanks,
> Ed Yakabosky
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
il.com>
wrote:
> Is there a tentative release date for Kafka 0.9.0?
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
you are hereby notified that any review, retransmission,
> dissemination, distribution, copying or other use of, or taking of any
> action in reliance upon this information is strictly prohibited. If you
> have received this communication in error, please contact the sender and
> delete the material from your computer.
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
'm trying to force Kafka into this territory it's not suited
> for. Have I been reading too many (awesome) articles about the role of the
> log and streaming in distributed computing? Or am I on the right track and
> I just need to put in some work to jump the hurdles (such as topic storage
>
I should set the right value
> >>for ³
> >> advertised.host.name², But setting that has no effect.
> >> Any help overcoming this will be appreciated.
> >>
> >> Am running version kafka_2.11-0.8.2.1.tgz on OS X.
> >>
> >> Regards,
> >> Sathya
> >>
> >>
> >
> >
> >--
> >-
> >"There are only 10 types of people in the world: Those who understand
> >binary, and those who don't"
>
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
umer is able to read them fine. It is just the
> console producer that doesn't seem to work (or at least as per the quick
> start link)
>
>
>
> Sent from my iPhone
>
> > On 28-Oct-2015, at 7:34 PM, Grant Henke <ghe...@cloudera.com> wrote:
> >
> > Hi Sathya,
&g
om>
wrote:
> Hi All,
>
> I would like to know what kind of strategy Kafka adopts in splitting
> partitions of a topic to across the cluster.
>
> Ex: if i have 10 broker in a cluster. 1 topic with 5 partition and each
> with replication-factor of 2. then how would Kafka w
us producer.
>
> Please can any one of you suggest a way to improve the performance of
> sync producer.
>
> Thanks,
> Santhakumari
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
ocumentation for basic queries.
> Please spend time finding the answers before sending queries to Kafka
> mailing list. In case you still not find answers Kafka community is there
> to help.
> Genuine queries do not get proper attention by all this clutter!
>
> Best,
> J
> > >
> > >producer = new KafkaProducer<String, byte[]>(props,
> keySerializer,
> > > valueSerializer);
> > >
> > > ProducerRecord<String, byte[]> imageRecord;
> > >
> > > while ( true ) {
> > > imageRecord = new ProducerRecord<String, byte[]>(topicName,
> > > record
Are you sure your producer and consumer are pointed to the same topic? I
see RECUR_TRANS in your logs but you mentioned creating RECURRING_TRANS.
If thats not the issue. I have a few questions to get more informations.
- Can you list & describe the relevant topics using the kafka-topics
ed?
> > Overflow, or something else?
> >
> > Thanks,
> >
> > Chad
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
s not been
> created. Any tips how to ensure/verify that offsets topic exists?
>
> Kind regards,
>
> Stevo Slavic.
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
;>
>> if i use kafkacat to generate a message on the topic i see
>> IllegalArgumentExceptions instead.
>>
>> this suggests that the two versions of kafka aren't compatible. is this
>> the case? does the whole ecosystem need to be on the same version?
>>
>> thank you,
>> doug
>>
>>
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
> for
> > > > deletion. (kafka.log.Log)*
> > > > *[2015-09-21 17:13:01,238] INFO Deleting segment 0 from log test-1.
> > > > (kafka.log.Log)*
> > > > *[2015-09-21 17:13:01,239] INFO Deleting index
> > > > /var/log/kafka/test-1/.index.deleted
> > > > (kafka.log.OffsetIndex)*
> > > >
> > > > I know the logs are still in there because i am using
> > > > the kafka-consumer-offset-checker.sh and it says how many messages
> the
> > > > logSize is.
> > > >
> > > > What am i missing in my configuration?
> > > >
> > > >
> > > >
> > > > Thanks!
> > > >
> > > > --
> > > > Allen Michael Chan
> > > >
> > >
> >
> >
> >
> > --
> > Allen Michael Chan
> >
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
ISR be 4, 3, 5 ?
>
> Does the ISR got to have the leader as the first replica ??
>
>
> Regards,
>
> Prabhjot
>
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
is the scale of data that is stored in Zookeeper ?
Looking forward for your help.
Thanks,
prabcs
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
of kafka broker are
welcome.
Thanks in advance.
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
+dev
Adding dev list back in. Somehow it got dropped.
On Mon, Aug 17, 2015 at 10:16 AM, Grant Henke ghe...@cloudera.com wrote:
Below is a list of candidate bug fix jiras marked fixed for 0.8.3. I don't
suspect all of these will (or should) make it into the release but this
should
, but are not in the list because they are not
committed yet.
Hope that helps the effort.
Thanks,
Grant
On Mon, Aug 17, 2015 at 12:09 AM, Grant Henke ghe...@cloudera.com wrote:
+1 to that suggestion. Though I suspect that requires a committer to do.
Making it part of the standard commit process could
, but in others have
purge after x amount of days.
I did some searches and I couldn't find anything related to this and it
appears that the compaction is enabled globally for all topics.
Thanks for all the information
Elias
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com
:
Will be nice to include Kafka-2308 and fix two critical snappy issues
in
the maintenance release.
Gwen
On Aug 14, 2015 6:16 AM, Grant Henke ghe...@cloudera.com wrote:
Just to clarify. Will KAFKA-2189 be the only patch in the release?
On Fri, Aug 14, 2015
an 0.8.2.2 release
just
to
fix this issue. Any objections?
Thanks,
Jun
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
,
Shahar.
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
envision for this is to have the thread check
the partition count via AdminUtils and only move on when the partition
count comes back as expected.
Thanks,
Chiara
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
quick/dirty (e.g. Poll DB at interval for
updates), to using another Kafka topic for new partition event
notifications (of course, we favor the latter, but timelines will likely
mean that the first option is what initially gets implemented).
On 8/7/15, 10:56 AM, Grant Henke ghe...@cloudera.com
to Kafka. Immediately after few seconds, command
output is:
MyTopic:0:64
Isn't this supposed to stay at 60 for longer time based on retention
policy?
Thanks,
Leena
On Thu, Aug 6, 2015 at 12:09 PM, Grant Henke ghe...@cloudera.com wrote:
Does this Spark Jira match up
working.
I have simple topic with just one partition.
I would appreciate any clues on how to debug this issue.
Thanks,
LCassa
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
the simpleConsumer ?
Thanks,
Prabhakar
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
the leaders to other
replicas, right? It won’t actually migrate any replicas elsewhere.
-Ao
On Aug 4, 2015, at 13:00, Grant Henke ghe...@cloudera.com wrote:
The broker will actually unregister itself from zookeeper. The brokers id
path uses ephemeral nodes so they are automatically destroyed
and wanted to find out
the lead broker for that partition.
Please provide your insights
Thanks
Sreeni
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
: DE 260543043
Management Board: Robert Gentz, David Schneider, Rubin Ritter
Chairperson of the Supervisory Board: Cristina Stenbeck
Registered office: Berlinn
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
just delete the znode for that broker once it has been shut down?
Thanks!
-Andrew Otto
--
Grant Henke
Software Engineer | Cloudera
gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
Also this stackoverflow answer may help: http://stackoverflow.com/a/29672325
On Fri, Jul 24, 2015 at 9:36 PM, Grant Henke ghe...@cloudera.com wrote:
I would actually suggest only using the ms versions of the retention
config. Be sure to check/set all the configs below and look
| (925) 400-3427
--
-Regards,
Mayuresh R. Gharat
(862) 250-7125
--
-Regards,
Mayuresh R. Gharat
(862) 250-7125
--
Grant Henke
Solutions Consultant | Cloudera
ghe...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
think it would not be unreasonable to drop support for
Scala
2.9.x in a future release, but I may be missing something. What do others
think?
Ismael
--
Grant Henke
Solutions Consultant | Cloudera
ghe...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
this value from the default?
Thank you,
Grant
--
Grant Henke
Solutions Consultant | Cloudera
ghe...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
at 11:21 PM, sunil kalva sambarc...@gmail.com
wrote:
thanks ghenke, that was a quick response. I will test and will let you
know if i have some questions.
On Tue, Mar 31, 2015 at 11:17 PM, Grant Henke ghe...@cloudera.com
wrote:
I think you are looking at is this section
if not able to send ?
--
SunilKalva
--
Grant Henke
Solutions Consultant | Cloudera
ghe...@cloudera.com | 920-980-8979
twitter.com/ghenke http://twitter.com/gchenke | linkedin.com/in/granthenke
returns true.
I expected AdminUtils.TopicExists() to check both BrokerTopicsPath
and DeleteTopicsPath before returning a verdict but it only checks
BrokerTopicsPath
Shouldn't a topic marked for deletion return false for topicExists() ?
--
Grant Henke
Solutions Consultant | Cloudera
ghe
62 matches
Mail list logo
