相关文章推荐
小百科
›
kafka-connect-s3/example-connect-worker.properties at master · wix-incubator/kafka-connect-s3 · GitH
飞翔的日光灯
3 月前
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Files
master
Breadcrumbs
kafka-connect-s3
/
example-connect-worker.properties
Blame
Blame
Latest commit
History
History
37 lines (31 loc) · 1.92 KB
master
Breadcrumbs
kafka-connect-s3
/
example-connect-worker.properties
Top
File metadata and controls
Code
Blame
37 lines (31 loc) · 1.92 KB
Raw
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
#
Licensed to the Apache Software Foundation (ASF) under one or more
#
contributor license agreements. See the NOTICE file distributed with
#
this work for additional information regarding copyright ownership.
#
The ASF licenses this file to You under the Apache License, Version 2.0
#
(the "License"); you may not use this file except in compliance with
#
the License. You may obtain a copy of the License at
#
#
http://www.apache.org/licenses/LICENSE-2.0
#
#
Unless required by applicable law or agreed to in writing, software
#
distributed under the License is distributed on an "AS IS" BASIS,
#
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#
See the License for the specific language governing permissions and
#
limitations under the License.
#
These are defaults. This file just demonstrates how to override some settings.
bootstrap.servers
=
localhost:9092
#
The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
#
need to configure these based on the format they want their data in when loaded from or stored into Kafka
key.converter
=
org.apache.kafka.connect.storage.StringConverter
value.converter
=
org.apache.kafka.connect.storage.StringConverter
#
The internal converter used for offsets and config data is configurable and must be specified, but most users will
#
always want to use the built-in default. Offset and config data is never visible outside of Copcyat in this format.
internal.key.converter
=
org.apache.kafka.connect.json.JsonConverter
internal.value.converter
=
org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable
=
true
internal.value.converter.schemas.enable
=
true
offset.storage.file.filename
=
/tmp/connect.offsets
#
Flush much faster than normal, which is useful for testing/debugging
offset.flush.interval.ms
=
5000
#
Reload metadata faster too so consumer picks up new topics
consumer.metadata.max.age.ms
=
10000
推荐文章