Skip to content

Commit 82d352b

Browse files
committed
replaced deprecated property name access
1 parent 35e9bd1 commit 82d352b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kcbq-connector/src/test/java/com/wepay/kafka/connect/bigquery/integration/BaseConnectorIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ protected void startConnect() {
123123
WorkerConfig.PLUGIN_DISCOVERY_CONFIG, "HYBRID_WARN");
124124

125125
Properties brokerProps = new Properties();
126-
brokerProps.put(KafkaConfig.MessageMaxBytesProp(), 10 * 1024 * 1024);
126+
brokerProps.put("message.max.bytes", 10 * 1024 * 1024);
127127

128128
connect = new EmbeddedConnectCluster.Builder()
129129
.name("kcbq-connect-cluster")

0 commit comments

Comments
 (0)