小编reg*_*all的帖子

我看过kafka文件,还不知道怎么消费一个主题并行？

假设:我有一个主题,如"发生了什么事"(不要拆分这个主题),我有很多客户想要使用它.那么我应该怎么做,以便多个客户可以并行使用它？我应该使用分区和客户组吗？

我对此有一个想法,但我不确定它是否正确.

针对同一主题制作多个分区,并为一个客户创建一个分区,因此一个生产者必须为这些分区生成相同的分区,并且不同客户组中的每个客户都是正确的？

声明快捷键F3似乎不适用于mac os 10.7.3的eclipse indigo,它总是显示仪表板和桌面选择的界面.我尝试ctrl + F3和命令+ F3始终不起作用.并且ctrl + click是我系统中的右键,我不想更改它.我想也许这是关键的设置问题,但我不知道它.可以帮助我.谢谢

我阅读了 Kafka wiki，对这张图片有一些问题。

1. 对于Consumer Group A，C1，C2，只能接收两个partition消息，像C1只接收P0，C2只接收P1？

2. 据我所知，一个Consumer Group映射一个Topic，所以C1、C2的Topic一定是一样的，所以PO、P1、P2、P3的Topic也是一样的，对吗？

3. 所以有一个矛盾，如果问题2是对的，那么消费者组A和消费者组B有相同的主题，所以一个消费者组映射一个主题的矛盾。

4. C1如何控制P0，P1消息，如果P0，P1有相同的topic，就意味着C1会收到重复的消息，如果不是，C1如何控制只有一个偏移量的不同消息？

5. 关于“所有分区都包含相同的主题，至少我是这样解释这张图片的”的问题。所以我假设，同一个主题名为“test”，然后一个生产者为这个主题生成消息“Hello test”，这意味着 C1 、C2、C3、C4都会收到同样的消息吗？对于第四个答案，C1 仍然收到两次“Hello test”？

6. CG-A 或 CG-B 能收到不同主题的消息吗？

7. 我没有看到 Consumer Group 的任何优势，“有时从 Kafka 读取消息的逻辑并不关心处理消息偏移量，它只需要数据。因此提供高级消费者来抽象大部分细节消费来自 Kafka 的事件。” 来自 Kafka 的 wiki，你能给我一个关于这张图片的消费者组的例子，比如你种子 CG-A 正在报告任务，而 CG-B 正在监控？

8. 这是否意味着来自一个名为“test”的主题的 P0、P1、P2、P3 会发送不同的消息？但我关注了 Kafka 的 wiki，比如：

   一种。bin/kafka-server-start.sh 配置/server.properties

   湾 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 3 --topic test //分区为3

   C。bin/kafka-console-producer.sh --broker-list localhost:9092 --topic 测试

   d. bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

   然后我在生产者中输入一些东西，然后消费者会显示这些信息？

那么这三个分区怎么会有不同的信息呢？

9. 最后，如何使用命令行来模拟这张图片？创建Consume Group，然后给它分配一个consumer，然后产生消息，我可以监控Partition和Consumer之间的映射关系，以及从哪个分区发送的消息？

非常感谢

我终于看到了一个Java拼图问题,并返回

    int i = 0;
    try {
        return i;
    } finally {
        i++;
    }

什么是这个函数的返回值,我知道这将返回0,我测试另一个代码

    StringBuffer sb = new StringBuffer("11");
    try {
        return sb;
    } finally {
        sb.append("22");
    }

这是奇怪的事情,它返回"1122" 这是我的第一个问题:为什么它返回"1122"？

我反编译这两个java代码,

    0:   iconst_0 put 0 to the stack
1:   istore_0 store the stack top into index 0
2:   iload_0  put index 0 to the stack 
3:   istore_1 store the stack top into index 1
4:   iinc    0, 1 inc the index 0 with 1
7:   iload_1 put index 1 …

我从http://engineering.linkedin.com/kafka/intra-cluster-replication-apache-kafka那里学到了什么.

我们的目标是支持在单个数据中心内的Kafka群集中进行复制,其中网络分区很少

在分布式系统中,我认为"分区"是基本的,所以我不知道当只有服务器节点失败时,Kafka保证没有分区的可用性.或者我想念一些东西

我只是声明数据数组

data = {0, 1, 2, 3, 4},  i = 1;  
data[i++] = data[i++] * 2;

我在Java和Javascript中测试,结果都是

{0, 4, 2, 3, 4}

一开始我觉得这对我来说太奇怪了

data[i++] * 2, data[1] * 2 = 2,

然后i变成2,然后data[2] = 2和i成3.所以结果应该是{0, 1, 2, 3, 4}.

有人能知道这个结果的原因吗？

我正在研究一个项目,它是一个cocoa静态库,它使用了由其他人编写的C++库.这个C++库使用了C++ 11和libc ++(支持C++ 11的LLVM C++标准库).

我成功构建了可可库,但是当我在App中链接这个库时(只需在"Link Binary with Libraries"中添加链接).

发生错误,这是错误日志:

"non-virtual thunk to std::__1::basic_iostream<char, std::__1::char_traits<char> >::~basic_iostream()", referenced from:


  "non-virtual thunk to std::__1::basic_iostream<char, std::__1::char_traits<char> >::~basic_iostream()", referenced from:


  "non-virtual thunk to std::__1::basic_istream<char, std::__1::char_traits<char> >::~basic_istream()", referenced from:


  "non-virtual thunk to std::__1::basic_istream<char, std::__1::char_traits<char> >::~basic_istream()", referenced from:


  "non-virtual thunk to std::__1::basic_istream<wchar_t, std::__1::char_traits<wchar_t> >::~basic_istream()", referenced from:


  "non-virtual thunk to std::__1::basic_istream<wchar_t, std::__1::char_traits<wchar_t> >::~basic_istream()", referenced from:


  "non-virtual thunk to std::__1::basic_ostream<char, std::__1::char_traits<char> >::~basic_ostream()", referenced from:


  "non-virtual thunk to std::__1::basic_ostream<char, std::__1::char_traits<char> >::~basic_ostream()", referenced from:


  "non-virtual thunk to std::__1::basic_ostream<wchar_t, std::__1::char_traits<wchar_t> >::~basic_ostream()", …