davideicardi

Alpakka Kafka connector (akka-stream-kafka) example

Simple solution to use Alpakka Kafka connector to produce and consume kafka messages.

I assume that you have 2 scala apps, a producer and a consumer.

Producer

Add the following dependencies:

sanjid133

#!/bin/bash

ETCD_VERSION=${ETCD_VERSION:-v3.3.1}

curl -L https://github.com/coreos/etcd/releases/download/$ETCD_VERSION/etcd-$ETCD_VERSION-linux-amd64.tar.gz -o etcd-$ETCD_VERSION-linux-amd64.tar.gz

tar xzvf etcd-$ETCD_VERSION-linux-amd64.tar.gz
rm etcd-$ETCD_VERSION-linux-amd64.tar.gz

cd etcd-$ETCD_VERSION-linux-amd64

dcaoyuan

        val uri = "http://www.yahoo.com"
        val reqEntity = Array[Byte]()

        val respEntity = for {
          request <- Marshal(reqEntity).to[RequestEntity]
          response <- Http().singleRequest(HttpRequest(method = HttpMethods.POST, uri = uri, entity = request))
          entity <- Unmarshal(response.entity).to[ByteString]
        } yield entity

        val payload = respEntity.andThen {

Asitha

  public boolean isLeader() {
    
    // Get all the Hazelcast instances in the current JVM.
    // In case of carbon server this is always either one 
    // or zero.
    Iterator<HazelcastInstance> iter
                        = Hazelcast.getAllHazelcastInstances().iterator();
    
    if (iter.hasNext()) { // cluster mode 

travisbrown

import com.twitter.finagle.Http;
import com.twitter.finagle.ListeningServer;
import com.twitter.finagle.Service;
import com.twitter.finagle.http.HttpMuxer;
import com.twitter.util.Await;
import com.twitter.util.Future;
import java.net.InetSocketAddress;
import static java.nio.charset.StandardCharsets.UTF_8;
import static org.jboss.netty.buffer.ChannelBuffers.copiedBuffer;
import org.jboss.netty.handler.codec.http.*;

hdubugras

VAGA DESENVOLVEDOR BACK-END

O Pagar.me está crescendo e o nosso time também. Para isso, estamos contratando desenvolvedores para nos ajudar a resolver os grandes problemas do mercado de pagamentos brasileiro. Nossa aplicação é escrita principalmente em Javascript (Node.js e AngularJS) e somos fortemente adeptos a novas tecnologias. Adoramos usar as ferramentas certas para resolver nossos problemas e somos totalmente obcecados por testes e filosofia open-source.

Não procuramos pessoas apenas excepcionais em Javascript, Ruby ou outra linguagem, mas também em computação em si. Queremos gente apaixonada por UNIX, otimização (incluindo do seu editor de texto), testes, segurança e consistência. Amamos os que programam desde a adolescência ou infância e que não consigam dormir até resolver um problema.

Seguem algumas reportagens sobre o pagar.me e os fundadores:

• http://www.forbesbrasil.co/negocios/pagar-empresa-foi-criada-por-dois-meninos-de-18-anos/
• http://www1.folha.uol.com.br/fsp/mercado/191204-empresar

deekayen

the
of
to
and
a
in
is
it
you
that

stonegao

class Respond extends Service[Request, Response] with Logger {
  def apply(request: Request) = {
    try {
      request.method -> Path(request.path) match {
        case GET -> Root / "todos" => Future.value {
          val data = Todos.allAsJson
          debug("data: %s" format data)
          Responses.json(data, acceptsGzip(request))
        }
        case GET -> Root / "todos" / id => Future.value {