回答情况：
提问时间：
问题标签：
假设我有一个使用唯一名称(由我设置)的线程，现在我想创建一个已经存在的具有相同名称的线程。如何终止/停止较旧的线程？下面是我用来识别是否存在同名线程的代码： processes.forEach(process -> { System.out.println("Yes Does Exi
浏览 0修改于2021-02-09得票数 0
我使用的是最新的landoop/fast-data-dev镜像(但是Kafka cli工具和upstream一样) 在容器中尝试此命令时： root@fast-data-dev / $ ./opt/landoop/kafka/bin/kafka-topics --bootstrap-server hostname:9093 --command-config client.properties -list 我得到了这个错误 [2020-11-26 18:09:01,580] WARN The configuration 'ssl.truststore.location' was
浏览 86提问于2020-11-27得票数 2
回答已采纳
sendMessages() { .forEach(val -> { consumer.subscribe(Arrays.asList("kafka-topicrecord); }
appli
浏览 1修改于2020-02-05得票数 0
我有一个需要将关系数据库中的数据更改发送到kafka-topic中的用例。我能够编写一个简单的JDBC程序，该程序执行一组针对特定时间段的更改的查询，并使用KafkaTemplate ( spring框架提供的包装器)将数据写入kafka-topic。
浏览 0提问于2019-07-24得票数 0
a topic but cannot read from it", "name": "write to test topic", } "name": "onload_kafka",
&qu
浏览 12修改于2021-12-17得票数 0
局部执行函数 CMD = "/dsapps/admin/edp/scripts/edp-admin.sh kafka-topict_out_lz def topic_offset_sl(self):
CMD = "/dsapps/admin/edp/scripts/edp-admin.sh kafka-topic
浏览 1修改于2020-06-20得票数 0
http://localhost:9200" password => "password"
index => "[kafka-topic
浏览 15提问于2019-10-15得票数 0
回答已采纳
新建kafka-topic时，有没有办法将所有分区的最小偏移量设置为大于0的值？如果没有直接的方法，是否有可能通过直接操作kafka内部偏移量的间接方法？
浏览 10提问于2017-12-15得票数 3
我使用查询"Create base_stream with“(kafka-topic ="myTopic"，format="avro")创建了一个流，这个主题拥有超过800 of的数据并在不断增长。
浏览 0修改于2020-05-13得票数 0
1回答
遇到了一个有趣的案例:有一些“空间”(Mq-queue，Kafka-topic，simple folder，诸如此类)。在这个空间中，以序列化的形式编写Java对象。有一个监听程序监听此空间。
浏览 0修改于2019-05-15得票数 0
我已经实现了一个Kafka Connect JDBC Source连接器，它连接到Oracle-Database，并将数据写入Kafka-Topic。
浏览 3提问于2021-02-18得票数 0
connection details
}
mutate => { add_field => { "kafka-topic
浏览 8提问于2022-09-13得票数 0
回答已采纳
kafka.notification.broker' => 'kafka:6667,kafka1:6667,kafka2:6667', 'kafka.notification.health.topic
' => 'Kafka-topic
浏览 37提问于2018-08-01得票数 0
a message to Kafka topic - vanilla", { "URL": "Kafka-topic
浏览 1修改于2019-09-18得票数 0
JDBC Source Kafka Connect有可能接受EVENT_STORE表的更改，并将它们与KAFKA-TOPIC中的列TYPE的值一起发布。
浏览 6修改于2019-12-07得票数 1
回答已采纳
properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");
properties.put("kafka-topic
浏览 1修改于2018-03-26得票数 1
spark-submit --master local[2] --jars /usr/lib/spark/lib/spark-examples.jar testfile.py <ZKhostname>:2181 <kafka-topicyarn --deploy-mode client --jars /usr/lib/spark/lib/spark-examples.jar testfile.py <ZKhostname>:2181 <<em
浏览 3提问于2018-01-16得票数 3
import KafkaConsumer consumer = KafkaConsumer(
'kafka-topic
浏览 3提问于2022-03-11得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号