2回答
我正在使用JDBC批插入插入许多记录。有没有办法为每条记录获取生成的键？可以将ps.getGeneratedKeys()与批插入一起使用吗？
我正在使用oracle.jdbc.OracleDriver
final String insert = "Insert into Student(RollNumber, Name, Age) values(StudentSEQ.nextval, ? , ?)";
final int BATCH_SIZE = 998;
int count = 0;
Connection con = null;
PreparedStatement ps =
浏览 1提问于2013-03-28得票数 12
回答已采纳
在使用Hibernate插入一些数据时，我得到了BatchUpdateException。当我尝试用sql编辑器插入下面的语句时，它没有抛出任何异常。有什么想法吗？
Caused by: java.sql.BatchUpdateException:
Batch entry 0 insert into registered_user (alias, id, register_time, title, type, uuid) values ('www.google.com', '0010001774', '2013-12-23T14:13:46',
浏览 0提问于2014-01-31得票数 0
在insert查询中，我使用序列，因此我拒绝使用SimpleJdbcInsert....executeBatch(数据)；
String sql = "INSERT INTO "+ schema +"."+ tableName +" (id, " + fieldName1 + ", " + fieldName2 + ") VALUES (BUF_SEQ.nextval, ?, ?)";
List<Object[]> recordValues = new ArrayList<Object[]>
浏览 1提问于2015-08-07得票数 0
2回答
到目前为止，我可以使用Teradata jdbc连接器for Spark从Teradata读取数据帧。阅读的语法如下：
val df = hc.read.format("jdbc").options(
Map(
"url" -> url,
"dbtable" -> (sel * from tableA) as data,
"driver" -> "com.teradata.jdbc.TeraDriver"
)
).load()
其中hc = hiveContex
浏览 1提问于2016-11-15得票数 2
2回答
我们必须将大量数据从HDD (~50 to )读入我们的数据库，但是我们的多线程过程非常慢(~2h (~10 to))，因为org.sqlite.core.NativeDB.reset[native]内部有线程锁(参见线程采样器)。
我们读取数据的速度相对较快，并使用insert方法执行准备好的语句。但是，只有当我们收集500.000个数据集时，我们才会将所有这些语句提交到数据库中。目前，我们使用JDBC作为sqlite数据库的接口。
到目前为止，如果使用一个线程总数，所有操作都很好。但是，如果要使用多个线程，则不会看到性能/速度有多大提高，因为只有一个线程可以同时运行，而不能并行运行。我们已
浏览 0提问于2017-05-04得票数 0
回答已采纳
我有一个Spring服务方法，它在同一个表上执行两个数据库操作。一个使用Hibernate会话工厂，另一个使用普通Spring。但是，我希望两者都绑定到一个事务中。使用下面的代码，它看起来像是创建了两个不同的事务，第一个事务锁定了第二个事务的表。
如何确保这两个操作都在单个事务下。？
我的服务类
@Service
public class MyService{
@Autowired
IMyDao mydao;
@Transactional
public void myMethod(){
...
mydao.save(entity); //This uses hibernate
浏览 0提问于2012-11-09得票数 1
回答已采纳
通过JDBC向TDSQL中批量插入数据报错，单条执行是可以的。请问这是TDSQL自己的限制嘛？
表结构
custom_event_report_realtime | CREATE TABLE `custom_event_report_realtime` (
`FId` int(10) unsigned NOT NULL AUTO_INCREMENT,
`FKFUin` bigint(20) NOT NULL,
`FTimestamp` bigint(20) NOT NULL,
`FUserID` varchar(100) NOT NULL,
`FEventName` var
浏览 998提问于2020-08-11
我们使用Hibernate 4.2作为JPA 2.0实体的后备库。我们有一个如下所示的实体：
@Entity
public class MyEntity {
....
@ElementCollection
@MapKeyColumn(name = "key")
@Column(name = "value")
@CollectionTable("MyEntityMap")
private Map<String, Integer> theMap;
...
}
该映射可能有数千个条目。
浏览 5提问于2013-05-16得票数 2
回答已采纳
1回答
如何在WSO2中使用事务
、、、、
我正在尝试使用transaction，同时通过WSO2将数据插入sql。但是事务不工作。我正在写示例代码。
<sequence xmlns="http://ws.apache.org/ns/synapse" name="InsertOrderSequence" onError="myFaultHandler">
<log level="full"></log>
<transaction action="new"></transaction>
&
浏览 1提问于2014-09-08得票数 2
1回答
我正在尝试使用原生查询进行大容量插入。 @Repository
public interface Repository extends CrudRepository<Entity, Integer> {
@Modifying
@Query(value = "INSERT INTO table_name(value) VALUES (:value)", nativeQuery = true)
void insert(@Param("value") String value);
} 我已经在application.proper
浏览 71提问于2020-08-27得票数 2
回答已采纳
2回答
我正在尝试插入一个100的表(我听说它是mySQL使用的最佳大小)，我在SBT0.13.6中使用Scala2.10.4，而我使用的jdbc框架是scalikejdbc和Hikaricp，我的连接设置如下所示：
val dataSource: DataSource = {
val ds = new HikariDataSource()
ds.setDataSourceClassName("com.mysql.jdbc.jdbc2.optional.MysqlDataSource");
ds.addDataSourceProperty("url", &#
浏览 5提问于2014-10-29得票数 1
回答已采纳
4回答
我正在尝试使用EclipseLink优化我的JPA实现。我给它增加了批处理操作。但是，做5万次插入还需要很长时间。使用原始SQL和JDBC执行完全相同的插入需要花费10倍以上的时间。
为了确保批处理操作实际上是有效的，我使用Wireshark检查包，并且它没有使用批处理插入。
以下是一个插入数据包：
它没有这样做：
INSERT INTO ENTITYCLASSTEST (LASTNAME, NAME) VALUES ('sfirosijfhgdoi 0', 'dsufius0'), ('sfirosijfhgdoi 0', '
浏览 3提问于2014-10-17得票数 6
回答已采纳
我使用mybatis将数据插入到postgresql数据库中。我有19629条记录要插入。我正在尝试一次插入所有记录。但是，如果我向查询传递超过6k条记录，则会得到原因: org.postgresql.util.PSQLException:发送到后端时发生I/O错误。
那么在postgresql中一次插入记录的数量是否有限制？
Mybatis代码。
{ @Insert({ "<script>","insert into temp_overdrive_csv_dtls (lpat_library_card_number,day_of_use,sessions,
浏览 1提问于2019-09-25得票数 0
7回答
问题是，我们有大量的记录(超过一百万条)要从Java应用程序插入到单个表中。这些记录是由Java代码创建的，而不是从另一个表移动，因此INSERT/SELECT不起作用。
目前，我的瓶颈是INSERT语句。我正在使用PreparedStatement来加速这个过程，但在一个普通的服务器上，我每秒不能获得超过50个重新编码。该表一点也不复杂，并且没有在其上定义索引。
这个过程耗时太长，而且耗费的时间会产生问题。
我可以做什么来获得最大的速度(插入每秒)？
数据库: MS SQL 2008。应用程序:基于Java，使用Microsoft JDBC驱动程序。
浏览 1提问于2010-05-04得票数 11
回答已采纳
1回答
我对R非常陌生，所以请原谅任何明显的或天真的错误。我需要将R中的多行数据插入Oracle数据库表中。
使数据框架(我在脚本前面已经建立了RJDBC连接)：
df <- data.frame("field_1" = 1:2, "field_2" = c("f","k"), "field_3"= c("j","t"))
此代码运行时没有出错，但只将第一行插入到表中：
insert <- sprintf("insert into temp_r_test_u_suck v
浏览 2提问于2018-10-19得票数 0
如何使用JOOQ?将Double.NaN插入到PostgreSQL“双精度”字段中
我使用的是PostgreSQL 9.5和JOOQ3.7.3。我正在将传感器值批量插入到表中。有时这个值是一个NaN，当JOOQ试图插入它时，它会抛出一个异常。
org.springframework.jdbc.BadSqlGrammarException: jOOQ; bad SQL grammar [];
nested exception is java.sql.BatchUpdateException: Batch entry 6
insert into "sensordata" (
浏览 4提问于2016-05-06得票数 1
回答已采纳
我使用apache camel和spring boot来实现两个表之间的集成流。源表包含超过1000条记录。我想要做的是在对源数据进行一些修改之后，这些数据应该插入到同一数据库中的另一个表中。我被数据插入阶段卡住了。 <camelContext id="Integrator" xmlns="http://camel.apache.org/schema/spring">
<route id="hello">
<from id="timer" uri=&#
浏览 47提问于2019-04-03得票数 0
2回答
kafka-connect-jdbc connector在特定的time.Here间隔后，批量连续发送相同的记录，这是我的连接器属性：
name=test-mssql-jdbc-autoincrement
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
tasks.max=1
connection.url=jdbc:jtds:sqlserver://localhost:1433/TESTDB;user=sa;password=sa12345
query=SELECT * FROM WF
浏览 2提问于2016-04-18得票数 3
我相信这个问题以前一定在论坛上被问过。但是我找不到它。如果你发现它是重复的，请将我重定向到特定的帖子。
我使用Spring JDBC和BeanPropertySqlParameterSource在oracle DB中插入记录。在插入记录之前，会调用一个序列来获取主键的值。
下面是我的方法的样子
public void insertTransaction(InTransaction transaction) {
Long txnId = getNextId(TXN_SEQUENCE);
transaction.setTxnId(txnId);
jd
浏览 6提问于2014-04-02得票数 0
1回答
我想通过Jooq实现如下的目标：
INSERT IGNORE INTO table1 (col1,col2,col3)
VALUES ('val1','val2','val3'),('val4','val5','val6');
但是使用一个pojos列表
类似于：
公共列表insertIgnoreMulti(列表记录){ //忽略如果存在返回dsl.batchStore(记录).execute()；}
但我似乎找不到这方面的文件。
谢谢。
我试过Lukas的例子：
public Loade
浏览 2提问于2017-04-12得票数 1
表agent_task_base有12000000行
curl -XPUT 'localhost:9200/river/myjdbc_river1/meta' -d '{
"type" : "jdbc",
"jdbc" : {
"url" : "...",
"user" : "...",
"password" : "...",
"sql
浏览 0提问于2014-02-22得票数 1
我需要在Vertica表上执行一些select*查询，并将这些查询放入MySQL table.But中，因为迭代，这可能是一个非常快的过程吗?有人能向我解释如何在java中实现hibernate或任何其他快速进程吗？
import java.io.IOException;
import java.sql.*;
public class Main {
public static void main(String args[]) throws SQLException, IOException, ClassNotFoundException {
try {
浏览 1提问于2017-09-27得票数 0
回答已采纳
3回答
这个程序一个接一个地执行数以万计的连续插入。我以前从来没有用过Hibernate。我得到了非常慢的性能(如果我只是手动连接并执行SQL，我的速度要快10-12倍。根据许多hibernate教程，我的batch_size设置为50。
这是一个单一插入的日志-也许你可以帮助我准确地理解发生了什么：
START INSERT
11:02:56.121 [main] DEBUG org.hibernate.impl.SessionImpl - opened session at timestamp: 13106053761
浏览 1提问于2011-07-14得票数 33
回答已采纳
1回答
当从服务层使用长List<Entity>调用我的JpaRepository的saveAll方法时，Hibernate的跟踪日志记录显示每个实体发出的单个List<Entity>语句。
我是否可以强制它进行批量插入(即多行)，而不需要手动处理EntityManger、事务等，甚至不需要处理原始SQL语句字符串？
对于多行插入，我的意思不仅仅是从以下位置转换：
start transaction
INSERT INTO table VALUES (1, 2)
end transaction
start transaction
INSERT INTO table VALUES
浏览 460提问于2018-06-09得票数 69
回答已采纳
我正在使用JDBC，并且想要批量插入，但是我需要为下一轮插入生成的键--有什么方法可以实现这一点吗？
MapSqlParameterSource[] batchArgs ....
DAL.getNamedParameterTemplate().batchUpdate("INSERT INTO...", batchArgs);
谢谢
浏览 3提问于2010-03-11得票数 16
1回答
我刚刚在本地安装了一个点击室服务器，带有clickhouse-server linux包。我创建了一些java代码来在表中插入N行，它通过JDBC工作得很好。然而，为了提高性能，我现在使用批处理而不是单独的插入来实现它，但是下面的代码不起作用，executeBatch函数返回一个长度为0的数组。
出于测试目的，我创建了以下代码：
public static void main(String[] args) throws PulsarClientException, SQLException {
Connection con = null;
String c
浏览 80提问于2021-03-11得票数 0
当在Swagger中测试我的应用程序并试图将一个条目发送到MySQL数据库时，我一直收到一个错误消息：java.sql.SQLIntegrityConstraintViolationException: Duplicate entry '0' for key 'PRIMARY'.当检查我的堆栈跟踪时，我可以在我的应用程序抛出错误消息之前看到以下行：
2017-09-12 12:55:11.394 INFO 642 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : Framework
浏览 2提问于2017-09-12得票数 0
3回答
我在Grails上使用大批量插入时遇到了很多麻烦。我尝试了用户提出的所有最常见的变通方法(如WithTransaction等)，但插入仍然慢得离谱。
我有一个包含大约500K对象的批次。在Gorm上，在DB中创建/插入对象的速度大约是每次插入200ms，这显然是不可接受的。如果我在转储文件中从应用程序生成相关的SQL insert语句，然后直接在DBMS上运行转储文件，则每次插入的时间小于1ms，这更像是这样。为了使批处理在线，我考虑了这个解决方案(伪Groovy代码)：
FileBuffer sqlFile = ...
largeBatch.each{
def obj = creat
浏览 3提问于2011-06-17得票数 0
我试图用基于Kafka的汇合式在几个MySQL数据库之间同步数据。我在源连接器配置中使用了"bulk“模式，因为主键类型是varchar，所以不能使用增量模式。很好，但我有两个问题：
它似乎无法同步删除，当数据在源数据库中被删除时，接收器数据库没有发生任何事情。数据仍然存在于接收器数据库中。
同步数据需要相当长的时间。在我的例子中，将表与3~4k行同步大约需要2~4分钟。我可以理解，使用大容量模式可能需要更多时间来同步数据，但这不是太长了吗？
下面是我的源连接器配置：
name=test-source
connector.class=io.confluent.conne
浏览 5提问于2017-09-19得票数 2
回答已采纳
我使用的是最新的EclipseLink版本和MySQL 5.5 (表类型InnoDB)。我一次插入大约30900张唱片(也可能更多)。问题是，insert性能非常差:插入所有记录需要大约22秒(与JDBC: 7秒相比)。我读过，使用批次书写应该有帮助-但没有！？
@Entity
public class TestRecord {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
public Long id;
public int test;
}
插入记录的代码：
factory = Persis
浏览 4提问于2011-06-21得票数 2
回答已采纳
我指的是这个文档。。根据文章，如果我们使用executeBatch方法，那么插入将会更快( Netezza JDBC驱动程序可能会检测到批量插入，并且在幕后将其转换为外部表加载，外部表加载将会更快)。我不得不执行数百万条insert语句，而且每个连接的最大速度仅为每分钟500条记录。有没有更好的方法通过jdbc连接更快地将数据加载到netezza？我使用spark和jdbc连接通过加载插入records.Why外部表，即使在批处理执行时也不会发生。下面给出了我使用的spark代码，
Dataset<String> insertQueryDataSet.foreachPartitio
浏览 19提问于2017-07-21得票数 1
3回答
这是我在阅读了几个关于jpa批量插入的主题后创建的简单示例，我有两个持久对象User和Site。一个用户可以有多个站点，所以我们这里有一对多的关系。假设我想创建用户，并创建/链接几个站点到用户帐户。考虑到我愿意对Site对象使用bulk insert，下面是代码的样子。
User user = new User("John Doe");
user.getSites().add(new Site("google.com", user));
user.getSites().add(new Site("yahoo.com", user));
Ent
浏览 0提问于2010-05-05得票数 25
回答已采纳
我正在使用Spring框架的JdbcTemplate机制。我还有调度器类来解析大型XML文件(>500 it )，这些文件在基于xml的配置中使用cron表达式调度，配置为池大小=10 .When调度器读取一个XML文件，解析每个元素并插入mariadb数据库，它插入大约8000条记录，但之后冻结或跳过一些记录，只有以下例外：
org.springframework.transaction.CannotCreateTransactionException: Could not open JDBC Connection for transaction; nested exception i
浏览 1提问于2019-06-17得票数 0
回答已采纳
1回答
我需要在使用Java的数据库上插入信息。它是关于信息检索的，我有一个1400个文档的集合，每个文档包含: ID，标题，作者，区域，摘要。我已经将集合组织成5个独立的字符串数组，去掉了不必要的字符和多个空格。如何将这些数据存储到我的集合数据库中一个名为Documents的表中？我在想像这样的..。
for(int i=0; i<=1400; i++){
user.execute("INSERT INTO Documents (idDoc, title, author, area,abstract)")
VALUES("+ID[i]+",
浏览 1提问于2014-10-20得票数 0
任务:我需要做至少10k记录插入作为一批。
实际上:在提交/刷新调用期间，我可以通过使用"SELECT * FROM TABLE“看到记录是完全随机插入的。比如它可以插入1k，然后是500，然后是1.5k，然后是500。这个批处理过程中发生了一些非常奇怪的事情。
我有非常基本的设置，如下所示：
<bean id="armDataSource"
class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverCla
浏览 2提问于2017-08-08得票数 1
我使用游标从一个大的postgres表中检索记录。(4亿条记录，使用子表对数据进行分区。)我的光标定义为：
select * from parent_table order by indexed_column
同时使用JDBC和psql，对于最初的几十万次检索，性能是一致的。在那之后，它就掉下了悬崖，再也不能恢复了。在服务器上，CPU、内存和磁盘活动相当均匀；也就是说，没有任何基于系统的东西是明显的罪魁祸首。我最初怀疑这可能是网络问题，但我从不同的网络重现了这一点。
下面是psql：
db@dbdev> fetch 100000 from all_persons;
Time: 13995
浏览 0提问于2012-07-29得票数 3
1回答
数据库更新-长时间运行操作失败
、、、、
我使用hibernate将一个对象放入DB中。DB是MYSQL社区版。整个更新将进入事务处理。
执行此操作的代码如下：
getHibernateTemplate().saveOrUpdate(目)；
当订单很小的时候没有问题，但是当我用将近1000件商品测试这个场景时，我遇到了这个问题：
11-22@12:56:48 DEBUG PersistOrderServiceImpl [flow.ottoImportOrderPlacementInboundFlow.1] - saving order instance::
[Order [orderId=080661, vatOrderNumbe
浏览 0提问于2011-11-23得票数 0
回答已采纳
但是大容量插入不起作用。
型号：
@Table(name = "user")
@Entity
public class User
{
@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE)
private Long id;
private String name;
}
存储库：
public interface IUserRepository extends JpaRepository<User, Long>
{
}
测试：
@SpringBootApplication
pub
浏览 4提问于2021-02-28得票数 0
1回答
我有一个名为Customer的mySQL数据库，我正在尝试从图形用户界面中的文本字段插入数据。我运行了下面的代码，在控制台中它显示“连接成功”，没有错误。我检查信息是否已经插入到我的mySQL数据库的Customer表中，但没有插入任何内容。有人知道为什么吗？
button.setOnAction(e -> {
Connection dbConnection = null;
PreparedStatement preparedStatement = null;
try {
Cus
浏览 0提问于2018-04-23得票数 0
2回答
我正在寻找类似于Java中的jdbc驱动程序的方式，在PHP中执行一批更新。
在jdbc中，有一个PreparedStatement.executeBatch()的API，它在一个到DB的往返过程中执行所有语句。
PHP PDO是否有类似的API，如果没有，启动事务、执行更新然后提交是否会产生相同的效果，即在一个到DB的往返过程中执行所有更新，或者每个更新都会往返到DB并立即执行语句(尽管其他人看不到，因为它在事务中)？
浏览 0提问于2013-03-29得票数 1
我试图在同一事务中插入并使用结果实体更新N条记录。
出现错误"FK不存在“，并以触发指令的相反顺序执行查询的日志跟踪。
服务：
@Transactional
public Entity1 createEntity(Entity1 newEntity){
Entity1 inserted = dao.createEntity(newEntity);
Integer numUpdated = dao.updateEntity2(newEntity)
return inserted;
}
Dao：
public Entity1 createEntity(Entity
浏览 2提问于2019-08-01得票数 0
回答已采纳
1回答
*我想在spring管理批处理作业中配置两个不同的数据库。但在运行应用程序时，只有"POSTGRES“数据库正在进行配置。是否可以为spring batch应用程序配置2个diff DB。我已经为这两个数据库添加了属性。它正在配置并运行应用程序。但是当我试图从不同的DB(二级)获取数据时。因此它不能映射表 batch.jdbc.url=jdbc:postgresql://localhost:5432/glow
batch.jdbc.driver=org.postgresql.Driver
batch.jdbc.user=postgres
batch.jdbc.password=pos
浏览 13提问于2019-09-08得票数 0
回答已采纳
在我的grails (1.3.7)应用程序中，我使用JDBC模板从CSV文件批量导入1000条记录(因为它比使用vanilla GORM/hibernate快得多，正如您所期望的那样)。
例如：
class Book {
String title
}
和
// For each CSV record...
insertStatementList.add("insert into book (id, title) values (nextval('hibernate_sequence'), thetitle)")
...
JdbcTemplate bulk
浏览 3提问于2012-09-19得票数 11
我有一个从数据库中获取大约470.000条记录的流。我要把这些记录放到销售队伍里。Salesforce只允许我在每次迭代中插入200条记录！不幸的是，我无法在一次db调用中获得所有这些记录，它会使机器内存超载。所以我的想法是在Mule中使用一个"foreach“组件来保持循环，直到我从db调用中得到少于200条记录。
如何实现这些目标呢？
我的配置流程如下：
<foreach batchSize="200" doc:name="For Each" counterVariableName="foreachCount">
浏览 1提问于2013-07-25得票数 2
2回答
在数据库中插入
、、
我使用mybatis插入值，使用：
Dao.xml
<insert id="someId" parameterType="someBean" >
INSERT ALL
<foreach collection="list" item="item" index="index" >
INTO table_name
(ID,NAME)
VALUES
(#{item.id},#{item.name})
<
浏览 4提问于2013-04-24得票数 1
回答已采纳
2回答
如何在多表中插入单行数据
、、、
在我们公司，我们有一个用例来解析一个有50k条记录的csv文件。我的任务是逐行读取csv文件，转换为对象，然后插入到多个表中。我使用sprint jdbc批处理机制将其写入到表中。现在我的问题是我无法将数据写入多个表。
insert into role(name, code) values(?,?);
insert into person(first_name, last_name, description, role_id) values(?,?,?,?);
谁能告诉我如何获得最后插入的role_id，然后将其传递给第二个查询。所有操作都发生在jdbcbatcupdate方法中。
浏览 4提问于2015-02-15得票数 1
正如你我都知道的，关于这类错误消息有很多问题。
但是我找不到任何好的答案，因为答案太多了。
我有一个存储从客户端发送的nonce的表。
但有时(偶尔) db会抱怨重复的主键插入，即使没有记录具有完全相同的主键。
下面是JVM所展示的内容。
[#|2012-11-09T11:06:52.098+0900|WARNING|glassfish3.1.2|javax.enterprise.system.container.ejb.com.sun.ejb.containers|_ThreadID=236;_ThreadName=Thread-2;|EJB5184:A system exception o
浏览 5提问于2012-11-09得票数 7
1回答
我想在pymongo的插入操作中使用多进程。在pymongo文档中，它涵盖了
Bulk_Insert操作。上面写着。
>>> import pymongo
>>> db = pymongo.MongoClient().bulk_example
>>> db.test.insert_many([{'i': i} for i in range(10000)]).inserted_ids
[...]
>>> db.test.count_documents({})
10000
insert_many操作本身是否支
浏览 19提问于2020-05-14得票数 0
使用Hibernate + Envers (Version5.2.17.Final)，我试图持久化大约250000个JPA实体，并使用Envers ValidityAuditStrategy审计初始插入。我正在使用JDBC批处理来提高性能。我看到两个人都在分批
插入基表(即INSERT INTO dbo.EXAMPLE_TABLE)
插入审计表(即INSERT INTO dbo.EXAMPLE_TABLE_AUD)
但对于用于更新以前所有审计行的结束修订的查询，我认为这是在设置allow_identifier_reuse=true时启用的(这对于我的用例来说是强制性的)。这些更
浏览 3提问于2018-12-21得票数 0
回答已采纳
尽管news表有超过6500万条记录，但我在Kafka主题中看不到任何记录。连接器配置：
curl -X POST http://localhost:8083/connectors -H "Content-Type: application/json" -d '{
"name": "news_fetcher",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcS
浏览 18提问于2021-06-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
