小编Geo*_*ith的帖子

我们有一个相当严格的网络细分政策.我正在使用云代工实例来部署应用程序.已设置防火墙规则以从云代工厂实例中到达kafka群集.我相信防火墙规则也已设置为访问zookeeper实例.我需要确实确认一个.

我的问题似乎是我可以向kafka发送消息,但我的消费者似乎并没有接受它们.它似乎在"投票"时挂起.

我的防火墙规则是否需要处理一些隐藏的主机或端口,而这些规则不仅仅是kafka和zookeeper节点的标准主机和端口？

我有一个使用ant进行构建的标准Java项目.我想在不中断当前流程的情况下为此项目添加spock测试.什么是允许我开始将spock测试集成到这个项目中的最小变化集.

关于spock与使用ant的遗留项目集成的可用信息不多.

我使用Confluent / Apache Kafka 0.10压缩主题作为分布式缓存同步机制。当应用程序启动时，它会生成一个特定于实例的consumer group id. 随着为水平可扩展性添加和删除实例，显然我们得到了大量不应再次使用的组 ID。

我确信这是KStreamsand的完美用例KTables，但出于智力原因以及KStreams和KTables被定义为 0.10 中的 alpha 质量，我正在尝试自己执行此操作。

是否有Kafka API我可以使用的调用可以删除现有的consumer group，知道它不应该再次使用？

由于Zookeeper没有维护消费者偏移量version 0.10，有没有办法删除consumer groupusing Kafka？

我正在为jboss ear应用程序编写EJB jar模块.我正在使用gradle,我不想尝试声明jar在运行时从JBoss那里依赖的所有不同依赖项.有没有办法声明目录树中所有文件的依赖项.

有没有办法让 Gradle 在使用“jar”任务时不压缩文件？

我一生都找不到任何有关为 jar 设置压缩设置的参考。

我有一个 kafka 0.10 集群，其中包含几个向它们生成消息的主题。

当我使用 KafkaConsumer 和新组 ID 订阅主题时，我不会返回任何记录，但是如果我使用以相同组 ID 寻求开头的 ConsumerRebalanceListener 订阅主题，那么我会获得主题中的记录。

@Grab('org.apache.kafka:kafka-clients:0.10.0.0')

import org.apache.kafka.clients.consumer.KafkaConsumer
import org.apache.kafka.clients.consumer.ConsumerRecords
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.apache.kafka.clients.consumer.ConsumerRebalanceListener
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.PartitionInfo

Properties props = new Properties()
props.with {
    put("bootstrap.servers","***********:9091")
    put("group.id","script-test-noseek")
    put("enable.auto.commit","true")
    put("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer")
    put("value.deserializer","org.apache.kafka.common.serialization.StringDeserializer")
    put("session.timeout.ms",30000)
}

KafkaConsumer consumer = new KafkaConsumer(props)
def topicMap = [:]
consumer.listTopics().each { topic, partitioninfo ->
        topicMap[topic] = 0
}

topicMap.each {topic, count ->
    def stopTime = new Date().time + 30_000
    def stop = false

    println "Starting topic: $topic"
    consumer.subscribe([topic])
    //consumer.subscribe([topic], new …

有谁知道我可以告诉我的Cloud Foundry实例监视我的运行状况终结点，以便当我的运行状况终结点指出应用程序运行状况不是状态：UP时，该应用程序已重新启动吗？

我刚开始使用Groovy.我确信我错过了一些愚蠢的东西.有人能告诉我为什么这个代码在groovy控制台中失败了吗？它认为输入字符串中只有14个单词和1行.

def input = """
line1: 50 65 42
line2: 123 456 352 753 1825
line3: 10 25 20 48 107
"""

words = input.split(/ /)
lines = input.split(/^/)
assert words.size() == 16
assert lines.size() == 3