Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5469

Created state changelog topics not logged correctly

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.0.0
    • Component/s: streams
    • Labels:
      None

      Description

      In the StreamPartitionAssignor class, the created state changelog topics aren't not logged correctly if the DEBUG log level is set.

      [2017-06-19 12:18:44,186] DEBUG stream-thread [streams-temperature-6d25c7ff-0927-4469-8ab3-24444685e7d8-StreamThread-1] Created state changelog topics {streams-temperature-KSTREAM-REDUCE-STATE-STORE-0000000002-changelog=org.apache.kafka.streams.processor.internals.StreamPartitionAssignor$InternalTopicMetadata@65ae7693} from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:477)
      

      against repartition topics which are well logged :

      [2017-06-19 12:18:37,871] DEBUG stream-thread [streams-temperature-6d25c7ff-0927-4469-8ab3-24444685e7d8-StreamThread-1] Created repartition topics [Partition(topic = streams-temperature-KSTREAM-REDUCE-STATE-STORE-0000000002-repartition, partition = 0, leader = none, replicas = [], isr = [])] from the parsed topology. (org.apache.kafka.streams.processor.internals.StreamPartitionAssignor:402)
      

      At same time if source topics are not created before launching the stream application, the state changelog topics log shows just {} (the placeholder) while for repartition topics the [] that is right because it's an empty list.

      It seems that there are two problems. For state changelog topics the values() is not used but then InternalTopicMetadata hasn't a toString() for having a well formatted output.
      I'm already working on that ..

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ppatierno Paolo Patierno
                Reporter:
                ppatierno Paolo Patierno
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: