小编Sam*_*ash的帖子

我已经搜索了所有内容，但找不到错误。我已经检查了这个 Stackoverflow 问题，但这不是我的问题

1. 我已经启动了一个动物园管理员服务器

   

启动服务器的命令是

 bin/zookeeper-server-start.sh config/zookeeper.properties

2. 然后我使用 Putty SSH 到 VM 并使用启动 kafka 服务器

   $ bin/kafka-server-start.sh config/server.properties

3. 然后我创建了 Kafka 主题，当我 列出主题时，它就会出现。

4. 然后我打开另一个腻子并启动 kafka-console-producer.sh 并输入任何消息（甚至输入）并得到这个冗长的重复异常。

zookeeper.properties、server.properties、kafka-producer.properties的配置文件如下（分别）

我运行的 Kafka 版本是 8.2.2。我在 kafka/libs 文件夹中看到的东西。 PS我在消费者中没有收到任何消息。

任何身体都可以找出问题吗？我遵循的教程是[这个][9]

8 http://%60http://www.bogotobogo.com/Hadoop/BigData_hadoop_Zookeeper_Kafka_single_node_single_broker_cluster.php%60

我对 Amazon Kinesis 和 Amazon DynamoDB 非常陌生。我为我的 RDS MySQL 数据库和 Dynamo DB 数据购买了 AWS 服务。现在我想利用我的 dynamo Db 数据。

通过使用 AWS 控制台界面，我想定期和实时地将 DynamoDB 新插入的记录推送到 S3。我已经阅读了 Kinesis，但我不确定如何在不使用应用程序开发的情况下安排此管道。如果可能的话，Kindle 引导我完成。谢谢

编辑 我阅读了 Kinesis Firehose 并想知道 dynamoDB 是否可以发布到 AWS Kinesis Firehose？

使用 Eclipse Luna 我试图运行一个导入已弃用的 google-collections 的 java 代码，该代码在使用最新的 Guava 版本编译时抛出异常。

public static void run(String consumerKey, String consumerSecret, String token, String secret) throws InterruptedException
{

    BlockingQueue<String> queue = new LinkedBlockingQueue<String>(10000);
    StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
    endpoint.trackTerms(Lists.newArrayList("twitterapi", "#AAPSweep"));
    Authentication auth = new OAuth1(consumerKey, consumerSecret, token, secret);

    Client client = new ClientBuilder()
    .hosts(Constants.STREAM_HOST)
    .endpoint(endpoint)
    .authentication(auth)
    .processor(new StringDelimitedProcessor(queue))
    .build();

    client.connect();

我尝试从插件中删除 com.google.guava_15.0.0.v201403281430 文件，并尝试粘贴 Guava 旧版本，如评论中所述所述，但我无法安装（指向）旧的 guava 版本。另外，这里可能还有另一种解决此问题的解决方案，但我是 java 新手，不知道如何用其他列表替换该列表。

请问有没有人可以使用其他 List 方法运行该代码？或者告诉我如何在 eclipse 中添加旧版本的 Guava（我不确定是否可以解决该问题，只需从线程中读取它）或者告诉我其他解决方案。谢谢