Hi, I am an engineer working in Tencent bigdata department. I am interested
in Apache edgent. I want to request contribute permission, Thanks.
Hi Justin Mclean:
You mean I do not need jira's "Assign" permission？ Just sending discussions
to mailing list, if the community accepts my idea, I could contribute my
code then send my PR to apache/edgent repository?
2018-02-25 12:12 GMT+08:00 Justin Mclean :
> Hi,
>
>
> > Hi, I am an enginee
Hi Justin Mclean:
OK, I know.
Thanks!
2018-02-25 13:10 GMT+08:00 Justin Mclean :
> Hi,
>
> > You mean I do not need jira's "Assign" permission？
>
> No but if you need that we can give you that without being committer.
>
> > Just sending discussions
> > to mailing list, if the community accepts
Hi :
I find there is no one RabbitMQ connector for edgent. I want to contribute
a RabbitMQ connector. How about this idea? Is there someone working for
this?
Thanks!
vinoyang
No one can give some comment？
2018-02-25 15:39 GMT+08:00 vino yang :
> Hi :
> I find there is no one RabbitMQ connector for edgent. I want to contribute
> a RabbitMQ connector. How about this idea? Is there someone working for
> this?
>
> Thanks!
> vinoyang
>
ion. As long as the needed libraries have Apache compatible
> licensees.
>
> Chris
>
> Outlook for Android<https://aka.ms/ghei36> herunterladen
>
> ____
> From: vino yang
> Sent: Monday, February 26, 2018 4:36:23 AM
> To: dev@edgent.ap
The reason is that Kafka 0.9+ provided a new consumer API which has more
features and better performance.
Just like Flink's implementation :
https://github.com/apache/flink/tree/master/flink-connectors.
vinoyang
Thanks.
ask Dale or someone who knows the inner workings a little more than
> me to re-check and do the merge.
>
> Chris
>
>
>
> Am 26.02.18, 07:22 schrieb "vino yang" :
>
> Hi christofer.dutz:
>
> Thanks for your reply! I will do this task.
>
>
Hi Christofer Dutz,
Is there any progress about this issue?
vino yang
Thanks.
2018-03-05 9:33 GMT+08:00 vino yang :
> Hi Christofer Dutz,
>
> That's all right. I think the RabbitMQ's licenses would not be a problem.
> There are many open source systems and libraries whic
+1 , I think we also could support to EdgexFoundry in the future.
2018-03-11 20:00 GMT+08:00 Christofer Dutz :
> Hi all,
>
> I am currently thinking of adding modules to support other IoT Platforms:
>
> * Google IoT
> * AWS IoT
> * Siemens MindSphere
>
> For that the “iotp” sort of do
Hi guys,
How about this idea, I think we should support kafka's new client API.
2018-03-04 15:10 GMT+08:00 vino yang :
> The reason is that Kafka 0.9+ provided a new consumer API which has more
> features and better performance.
>
> Just like Flink's implementation : htt
Zoo of adapters
> for Kafka.
>
> Eventually a Kafka-Streams client would make sense though ... to sort of
> extend the Edgent streams from the edge to the Kafka cluster.
>
> Chris
>
>
>
> Am 12.03.18, 03:41 schrieb "vino yang" :
>
> Hi guys,
>
>
Hi Chris,
OK, Hope for listening someone's opinion.
Vino yang.
2018-03-12 20:23 GMT+08:00 Christofer Dutz :
> Hi Vino,
>
> please don't interpret my opinion as some official project decision.
> For discussions like this I would definitely prefer to hear the opinions
>
ntain, test,
> document etc. loads of separate modules.
>
> Chris
>
>
>
> Am 12.03.18, 13:30 schrieb "vino yang" :
>
> Hi Chris,
>
> OK, Hope for listening someone's opinion.
>
> Vino yang.
>
> 2018-03-12 20:23 GMT+08:00 Christo
Hi guys,
Does Edgent current support groupBy operator?
Vino yang
Thanks.
Hi Chris,
No objections about this approach. Good division of the work. I will
provide the mapping of Kafka version and the specified feature later.
Vino yang
Thanks.
2018-03-13 20:11 GMT+08:00 Christofer Dutz :
> Well I have implemented something like the Version checking before, so I
>
ol max records, introduced
"max.poll.records" config item
- 0.10.x -> 0.11.x : support producer exactly-once (with
*beginTransaction*/*commitTransaction *API)
- 0.11.x -> 1.x : seems no specific feature which affect the API
Vino yang
Thanks.
2018-03-14 9:27 GMT+08:00 v
Hi all,
Anyone can give some opinion? Chris ? I think we should support some reduce
operation(aggregation function, such as max / avg / min sum) for both
stream and windowed stream, these features based on the keyBy or groupBy
operation.
Vino yang
Thanks!
2018-03-13 12:52 GMT+08:00 vino yang
y are similar with each other in some ways.
Vino yang.
Thanks!
2018-03-20 17:05 GMT+08:00 Christofer Dutz :
> Hi Vino,
>
> unfortunately I can't contribute any opinion on this as I don't yet
> understand the consequences.
> I know that in an asynchronous event processing
ion to the project now?
Vino yang
Thanks
2018-03-20 17:28 GMT+08:00 vino yang :
> Hi Chris,
>
> My background is BigData (MapReduce, Spark, Flink, Kafka Stream) those
> data processing frameworks all provide the groupBy / keyBy operation and
> aggregation operator. It comes from traditi
Hi Chris,
I will try to do this, if I have any question, keep in touch!
Vino yang
Thanks.
2018-03-20 17:32 GMT+08:00 Christofer Dutz :
> Ok,
>
> So I just added a new Annotation type to the Kafka module.
>
> org.apache.edgent.connectors.kafka.annotations.KafkaVersion
>
>
,such as map, flatmap, filter, reduce...
and so on.
Vino yang.
Thanks.
2018-03-20 20:51 GMT+08:00 Christofer Dutz :
> Hi,
>
> have been using the Kafka integration quite often in the past and one
> thing I always have to explain when demonstrating code and which seems to
> confuse
Hi Dale,
When I wroted the RabbitMQ connector I followed the Kafka Connector's style
(and I also looked the MQTT connectors). And I chose the Kafka connector as
the implementation template. The reason is the two classes
(RabbitmqProducer and RabbitmqConsumer) should not share one rabbitmq's
connec
urce / sink or some other edgent self-created
named all connectors should follow this specification.
Vino yang
Thanks.
2018-03-23 0:56 GMT+08:00 Christofer Dutz :
> Hi Dale,
>
> Happy to read from you :-)
>
> It was just something I had to explain every time I showed the code for
Hi Chris,
You did a great job! It's good for expanding the edgent's influence!
Vino yang
Thanks.
2018-03-23 17:57 GMT+08:00 Christofer Dutz :
> Hi,
>
> today I bought the magazine with my Article and was totally amazed that it
> has become one of the cover-page arti
the scenario there is only one connection) . So I think we should take it
easy about the case you described.
Vino yang.
Thanks.
2018-03-27 4:27 GMT+08:00 Dale LaBossiere :
> Hi Vino, thanks for the clarification.
>
> One last question :-). Is there ever a situation when it’s
> desira
Hi Chris,
I have not done this. And I would upgrade it soon.
Vino yang
Thanks!
2018-04-04 19:23 GMT+08:00 Christofer Dutz :
> Hi,
>
> so I updated the libs locally, built and re-ran the example with this
> version and it now worked without any problems.
>
> Chris
>
>
Hi Chris,
I rechecked the old mails between you and me. I misunderstand your message.
I thought you will create the annotation. In fact, you have created the
annotation.
I will do this work soon, hold on.
Vino yang.
Thanks.
2018-04-04 19:32 GMT+08:00 vino yang :
> Hi Chris,
>
> I
Hi Chris, Take it easy, I think the compile failure may not affect a lot. I am
glad to hear that higher Kafka client can be backward compatible well.
Vino yang Thanks. On 2018-04-04 23:21 , Christofer Dutz Wrote: Hi Vino, Yeah
... but I did it without an ASF header ... that's why the
29 matches
Mail list logo
