connect-distributed.properties 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. ##
  2. # Licensed to the Apache Software Foundation (ASF) under one or more
  3. # contributor license agreements. See the NOTICE file distributed with
  4. # this work for additional information regarding copyright ownership.
  5. # The ASF licenses this file to You under the Apache License, Version 2.0
  6. # (the "License"); you may not use this file except in compliance with
  7. # the License. You may obtain a copy of the License at
  8. #
  9. # http://www.apache.org/licenses/LICENSE-2.0
  10. #
  11. # Unless required by applicable law or agreed to in writing, software
  12. # distributed under the License is distributed on an "AS IS" BASIS,
  13. # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14. # See the License for the specific language governing permissions and
  15. # limitations under the License.
  16. ##
  17. # These are defaults. This file just demonstrates how to override some settings.
  18. bootstrap.servers=localhost:9092
  19. group.id=connect-cluster
  20. # The converters specify the format of data in Kafka and how to translate it into Connect data. Every Connect user will
  21. # need to configure these based on the format they want their data in when loaded from or stored into Kafka
  22. key.converter=org.apache.kafka.connect.json.JsonConverter
  23. value.converter=org.apache.kafka.connect.json.JsonConverter
  24. # Converter-specific settings can be passed in by prefixing the Converter's setting with the converter we want to apply
  25. # it to
  26. key.converter.schemas.enable=true
  27. value.converter.schemas.enable=true
  28. # The internal converter used for offsets and config data is configurable and must be specified, but most users will
  29. # always want to use the built-in default. Offset and config data is never visible outside of Copcyat in this format.
  30. internal.key.converter=org.apache.kafka.connect.json.JsonConverter
  31. internal.value.converter=org.apache.kafka.connect.json.JsonConverter
  32. internal.key.converter.schemas.enable=false
  33. internal.value.converter.schemas.enable=false
  34. offset.storage.topic=connect-offsets
  35. # Flush much faster than normal, which is useful for testing/debugging
  36. offset.flush.interval.ms=10000
  37. config.storage.topic=connect-configs