Resultados da pesquisa a pedido "apache-kafka"
Opções de API do Kafka Create Topic para idiomas não Java
Enquanto você pode criar um tópico via Java ou linguagens baseadas em Java (consulteaqui [https://stackoverflow.com/questions/18225263/kafka-0-8-is-it-possible-to-create-topic-with-partition-and-replication-using-j] ), não parece haver uma ...
Consumidor Kafka Avro com problemas de decodificador
Quando tentei correrConsumidor Kafka com Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12]sobre os dados com meu esquema respectivo, ele retorna um erro de "AvroRuntimeException: dados malformados. O comprimento é negativo: -40". Vejo ...
O Apache Kafka é apropriado para uso como uma fila de tarefas não ordenadas?
Kafka divide as mensagens recebidas em partições, de acordo com a partição atribuída pelo produtor. As mensagens das partições são consumidas pelos consumidores em diferentes grupos de consumidores. Essa arquitetura me deixa desconfiado de usar ...
O JBOSS fornece org.apache.kafka.common.KafkaException: auth.conf não pode ser lido
Quando implanto guerra do meu projeto kafka simples (que funciona bem como um jar) no wildfly v 10, recebo uma exceção de conexão do zookeeper [1]. Isso ocorre quando o ouvinte kafka começa a se conectar ao zookeeper [1]] 15:21:58,531 ERROR ...
obter tópico da mensagem kafka no spark
Em nosso trabalho de streaming de faísca, lemos mensagens em streaming de kafka. Para isso, usamos oKafkaUtils.createDirectStream API que retornaJavaPairInputDStreamfrom. As mensagens são lidas do kafka (de três tópicos - test1, test2, test3) ...
Opção de VM Kafka não reconhecida 'PrintGCDateStamps'
Instalei o Kafka em um servidor remoto e, quando tentei executar ~/kafka/bin/zookeeper-server-start.sh ~/kafka/config/zookeeper.propertiesE eu recebi um erro Unrecognized VM option 'PrintGCDateStamps'E o servidor kafka falhou ao iniciar. Isso ...
Quais são as limitações de nome de tópico do Apache Kafka?
Eu apenas tentei criar um tópico Kafka"user:created" e viu esse erro nos logs do Kafka:Invalid character ':' in value part of property. Pesquisei no Google e descobri que em uma lista de discussão as pessoas estão falando em depreciar. ...
Utilize o esquema para converter mensagens AVRO com Spark em DataFrame
Existe uma maneira de usar um esquema para converter avro [/questions/tagged/avro] mensagens de kafka [/questions/tagged/kafka] comfaísc [/questions/tagged/spark] paraquadro de dado [/questions/tagged/dataframe]? O arquivo de esquema para ...
Assert Kafka enviar funcionou
Estou escrevendo um aplicativo com o Spring Boot para escrever no Kafk @Autowired private KafkaTemplate<String, String> kafkaTemplate;e depois dentro do meu método: kafkaTemplate.send(topic, data)Mas sinto que estou apenas contando com isso ...