Home Explore Help
Sign In
recycle
/
dm
2
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Tree: e13a431ded
Branches Tags
dm
/
conf
/
java
/
kafka
/
connect-distributed.properties

connect-distributed.properties 2.1 KB
History Raw

123456789101112131415161718192021222324252627282930313233343536373839404142 
  1. ##
    2. 

  2. # Licensed to the Apache Software Foundation (ASF) under one or more
    3. 

  3. # contributor license agreements.  See the NOTICE file distributed with
    4. 

  4. # this work for additional information regarding copyright ownership.
    5. 

  5. # The ASF licenses this file to You under the Apache License, Version 2.0
    6. 

  6. # (the "License"); you may not use this file except in compliance with
    7. 

  7. # the License.  You may obtain a copy of the License at
    8. 

  8. #
    9. 

  9. #    http://www.apache.org/licenses/LICENSE-2.0
    10. 

  10. #
    11. 

  11. # Unless required by applicable law or agreed to in writing, software
    12. 

  12. # distributed under the License is distributed on an "AS IS" BASIS,
    13. 

  13. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    14. 

  14. # See the License for the specific language governing permissions and
    15. 

  15. # limitations under the License.
    16. 

  16. ##
    17. 

  17. 

  18. # These are defaults. This file just demonstrates how to override some settings.
    19. 

  19. bootstrap.servers=localhost:9092
    20. 

  20. 

  21. group.id=connect-cluster
    22. 

  22. 

  23. # The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
    24. 

  24. # need to configure these based on the format they want their data in when loaded from or stored into Kafka
    25. 

  25. key.converter=org.apache.kafka.connect.json.JsonConverter
    26. 

  26. value.converter=org.apache.kafka.connect.json.JsonConverter
    27. 

  27. # Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply
    28. 

  28. # it to
    29. 

  29. key.converter.schemas.enable=true
    30. 

  30. value.converter.schemas.enable=true
    31. 

  31. 

  32. # The internal converter used for offsets and config data is configurable and must be specified, but most users will
    33. 

  33. # always want to use the built-in default. Offset and config data is never visible outside of Copcyat in this format.
    34. 

  34. internal.key.converter=org.apache.kafka.connect.json.JsonConverter
    35. 

  35. internal.value.converter=org.apache.kafka.connect.json.JsonConverter
    36. 

  36. internal.key.converter.schemas.enable=false
    37. 

  37. internal.value.converter.schemas.enable=false
    38. 

  38. 

  39. offset.storage.topic=connect-offsets
    40. 

  40. # Flush much faster than normal, which is useful for testing/debugging
    41. 

  41. offset.flush.interval.ms=10000
    42. 

  42. config.storage.topic=connect-configs
    43.