mqtt kafka bridge install - erro 'anotações não são suportadas na fonte 1.3'

Question

Estou tentando instalar o MQTT KAFKA no Ubuntu e recebendo um erro de 'anotações não são suportadas na origem 1.3' quando executamos o comando ANT cmd.

A partir da pesquisa do problema, vemos que algumas correções estão disponíveis, mas não solucionaram nosso problema:

• Defina o diretório Java_Home para corrigir a versão
• editar pom.xml java versão 1.7

Eu suspeito que isso tenha algo a ver com a configuração do java, já que vi outros problemas de instalação, mas não posso ter certeza, devido à minha proeza limitada em sistemas Linux.

Qualquer ajuda seria muito apreciada!

    

Answer 1

Havia alguns itens com isso:

1. é necessária uma dependência chamada Paho Java MQTT Client. Isso pode ser instalado manualmente no site do Paho, use a versão 0.4.0. Execute mvn clean install para adicioná-lo ao seu repositório maven local e, em seguida, edite o pom.xml que vem com o mqttKafkaBridge para apontar para os arquivos jar e pom que foram adicionados ao seu repositório local. Parece haver um erro no pom.xml que vem com mqttKafkaBridge como ele se refere Paho 0.9.0, que não existe e alterá-lo para 0.4.0 não resolve-lo.Certifique-se de executar mvn clean install na pasta de nível superior, não em nenhuma das subpastas. Também atente para um problema de compilação com o arquivo ClientComms.java. Para corrigir isso, edite o arquivo build.xml sob a pasta org.eclipse.paho.client.mqttv3 para apontá-lo para o local correto para ClientComms.java, ou seja: / src / main / java-templates / org / eclipse / paho /client/mqttv3/internal/ClientComms.java

2. kafka 0.7.2 também é necessário. não vai funcionar com 0.8.0-beta1 (eu testei ambos). para obter o 0.7.2, faça o download do código-fonte e instale usando o sbt (ferramenta de construção simples), consulte: link . Infelizmente isso não adiciona kafka 0.7.2 ao seu repositório local. Para fazer isso, vá para o diretório de origem kafka e execute: mvn install: arquivo-de-instalação -Dfile = core / target / scala_2.8.0 / kafka-0.7.2.jar -DgroupId = org.apache.kafka -DartifactId = kafka - Dversion = 0.7.2 -Dpackaging = jar. Então você precisa voltar para o mqttKafkaBridge e editar a dependência do kafka no arquivo pom.xml para apontar para isso. Executando ./sbt publish-local & & O ./sbt publish para o kafka 0.8.0-beta1 funcionará e o adicionará ao seu repositório maven local (.m2 / repository), mas a compilação mqttKafkaBridge falhará informando que o kafka 0.8.0-beta1 não é válido. Executando o ./sbt publish-local funciona para o kafka 0.7.2, mas a publicação ./sbt falha, portanto, é necessário usar a rota mvn install: install-file (que não funciona para o 0.8.0-beta1).

3. último passo também foi difícil. Encontrei um link sobre isso que ajudou a resolvê-lo para mim: link . O artigo sugere que o ANT não funcionará para compilá-lo e usar o maven. execute mvn clean install em vez de ANT e deve compilar para você.

não há muita documentação disponível, e os componentes e versões foram desenvolvidos recentemente, por isso, esperamos que este post ajude outras pessoas com o problema.