16:52:48.142 [main] INFO i.d.c.c.CassandraConnectorTask - Initializing Cassandra connector task context ... 16:52:48.151 [main] INFO o.a.c.config.YamlConfigurationLoader - Configuration location: file:////etc/cassandra/cassandra.yaml 16:52:48.152 [main] DEBUG o.a.c.config.YamlConfigurationLoader - Loading settings from file:////etc/cassandra/cassandra.yaml 16:52:48.325 [main] INFO org.apache.cassandra.config.Config - Node configuration:[allocate_tokens_for_keyspace=null; authenticator=AllowAllAuthenticator; authorizer=AllowAllAuthorizer; auto_bootstrap=true; auto_snapshot=true; back_pressure_enabled=false; back_pressure_strategy=org.apache.cassandra.net.RateBasedBackPressure{high_ratio=0.9, factor=5, flow=FAST}; batch_size_fail_threshold_in_kb=50; batch_size_warn_threshold_in_kb=5; batchlog_replay_throttle_in_kb=1024; broadcast_address=172.21.0.5; broadcast_rpc_address=172.21.0.5; buffer_pool_use_heap_if_exhausted=true; cas_contention_timeout_in_ms=1000; cdc_enabled=true; cdc_free_space_check_interval_ms=250; cdc_raw_directory=/var/lib/cassandra/cdc_raw; cdc_total_space_in_mb=1024; client_encryption_options=; cluster_name=Test Cluster; column_index_cache_size_in_kb=2; column_index_size_in_kb=64; commit_failure_policy=stop; commitlog_compression=null; commitlog_directory=/var/lib/cassandra/commitlog; commitlog_max_compression_buffers_in_pool=3; commitlog_periodic_queue_size=-1; commitlog_segment_size_in_mb=1; commitlog_sync=periodic; commitlog_sync_batch_window_in_ms=NaN; commitlog_sync_period_in_ms=10000; commitlog_total_space_in_mb=null; compaction_large_partition_warning_threshold_mb=100; compaction_throughput_mb_per_sec=16; concurrent_compactors=null; concurrent_counter_writes=32; concurrent_materialized_view_writes=32; concurrent_reads=32; concurrent_replicates=null; concurrent_writes=32; counter_cache_keys_to_save=2147483647; counter_cache_save_period=7200; counter_cache_size_in_mb=null; counter_write_request_timeout_in_ms=5000; credentials_cache_max_entries=1000; credentials_update_interval_in_ms=-1; credentials_validity_in_ms=2000; cross_node_timeout=false; data_file_directories=[Ljava.lang.String;@31f924f5; disk_access_mode=auto; disk_failure_policy=stop; disk_optimization_estimate_percentile=0.95; disk_optimization_page_cross_chance=0.1; disk_optimization_strategy=ssd; dynamic_snitch=true; dynamic_snitch_badness_threshold=0.1; dynamic_snitch_reset_interval_in_ms=600000; dynamic_snitch_update_interval_in_ms=100; enable_materialized_views=true; enable_scripted_user_defined_functions=false; enable_user_defined_functions=false; enable_user_defined_functions_threads=true; encryption_options=null; endpoint_snitch=SimpleSnitch; file_cache_round_up=null; file_cache_size_in_mb=null; gc_log_threshold_in_ms=200; gc_warn_threshold_in_ms=1000; hinted_handoff_disabled_datacenters=[]; hinted_handoff_enabled=true; hinted_handoff_throttle_in_kb=1024; hints_compression=null; hints_directory=/var/lib/cassandra/hints; hints_flush_period_in_ms=10000; incremental_backups=false; index_interval=null; index_summary_capacity_in_mb=null; index_summary_resize_interval_in_minutes=60; initial_token=null; inter_dc_stream_throughput_outbound_megabits_per_sec=200; inter_dc_tcp_nodelay=false; internode_authenticator=null; internode_compression=dc; internode_recv_buff_size_in_bytes=0; internode_send_buff_size_in_bytes=0; key_cache_keys_to_save=2147483647; key_cache_save_period=14400; key_cache_size_in_mb=null; listen_address=172.21.0.5; listen_interface=null; listen_interface_prefer_ipv6=false; listen_on_broadcast_address=false; max_hint_window_in_ms=10800000; max_hints_delivery_threads=2; max_hints_file_size_in_mb=128; max_mutation_size_in_kb=null; max_streaming_retries=3; max_value_size_in_mb=256; memtable_allocation_type=heap_buffers; memtable_cleanup_threshold=null; memtable_flush_writers=0; memtable_heap_space_in_mb=null; memtable_offheap_space_in_mb=null; min_free_space_per_drive_in_mb=50; native_transport_flush_in_batches_legacy=true; native_transport_max_concurrent_connections=-1; native_transport_max_concurrent_connections_per_ip=-1; native_transport_max_frame_size_in_mb=256; native_transport_max_threads=128; native_transport_port=9042; native_transport_port_ssl=null; num_tokens=256; otc_backlog_expiration_interval_ms=200; otc_coalescing_enough_coalesced_messages=8; otc_coalescing_strategy=DISABLED; otc_coalescing_window_us=200; partitioner=org.apache.cassandra.dht.Murmur3Partitioner; permissions_cache_max_entries=1000; permissions_update_interval_in_ms=-1; permissions_validity_in_ms=2000; phi_convict_threshold=8.0; prepared_statements_cache_size_mb=null; range_request_timeout_in_ms=10000; read_request_timeout_in_ms=5000; request_scheduler=org.apache.cassandra.scheduler.NoScheduler; request_scheduler_id=null; request_scheduler_options=null; request_timeout_in_ms=10000; role_manager=CassandraRoleManager; roles_cache_max_entries=1000; roles_update_interval_in_ms=-1; roles_validity_in_ms=2000; row_cache_class_name=org.apache.cassandra.cache.OHCProvider; row_cache_keys_to_save=2147483647; row_cache_save_period=0; row_cache_size_in_mb=0; rpc_address=0.0.0.0; rpc_interface=null; rpc_interface_prefer_ipv6=false; rpc_keepalive=true; rpc_listen_backlog=50; rpc_max_threads=2147483647; rpc_min_threads=16; rpc_port=9160; rpc_recv_buff_size_in_bytes=null; rpc_send_buff_size_in_bytes=null; rpc_server_type=sync; saved_caches_directory=/var/lib/cassandra/saved_caches; seed_provider=org.apache.cassandra.locator.SimpleSeedProvider{seeds=cassandra-seed}; server_encryption_options=; slow_query_log_timeout_in_ms=500; snapshot_before_compaction=false; ssl_storage_port=7001; sstable_preemptive_open_interval_in_mb=50; start_native_transport=true; start_rpc=false; storage_port=7000; stream_throughput_outbound_megabits_per_sec=200; streaming_keep_alive_period_in_secs=300; streaming_socket_timeout_in_ms=86400000; thrift_framed_transport_size_in_mb=15; thrift_max_message_length_in_mb=16; thrift_prepared_statements_cache_size_mb=null; tombstone_failure_threshold=100000; tombstone_warn_threshold=1000; tracetype_query_ttl=86400; tracetype_repair_ttl=604800; transparent_data_encryption_options=org.apache.cassandra.config.TransparentDataEncryptionOptions@5579bb86; trickle_fsync=false; trickle_fsync_interval_in_kb=10240; truncate_request_timeout_in_ms=60000; unlogged_batch_across_partitions_warn_threshold=10; user_defined_function_fail_timeout=1500; user_defined_function_warn_timeout=500; user_function_timeout_policy=die; windows_timer_interval=1; write_request_timeout_in_ms=2000] 16:52:48.325 [main] DEBUG o.a.c.config.DatabaseDescriptor - Syncing log with a period of 10000 16:52:48.325 [main] INFO o.a.c.config.DatabaseDescriptor - DiskAccessMode 'auto' determined to be mmap, indexAccessMode is mmap 16:52:48.325 [main] INFO o.a.c.config.DatabaseDescriptor - Global memtable on-heap threshold is enabled at 274MB 16:52:48.325 [main] INFO o.a.c.config.DatabaseDescriptor - Global memtable off-heap threshold is enabled at 274MB 16:52:48.329 [main] INFO o.a.c.config.DatabaseDescriptor - cdc_enabled is true. Starting casssandra node with Change-Data-Capture enabled. 16:52:48.402 [main] WARN o.a.c.config.DatabaseDescriptor - Only 45.981GiB free across all data volumes. Consider adding more capacity to your cluster or removing obsolete snapshots 16:52:48.420 [main] INFO o.a.c.net.RateBasedBackPressure - Initialized back-pressure with high ratio: 0.9, factor: 5, flow: FAST, window size: 2000. 16:52:48.420 [main] INFO o.a.c.config.DatabaseDescriptor - Back-pressure is disabled with strategy org.apache.cassandra.net.RateBasedBackPressure{high_ratio=0.9, factor=5, flow=FAST}. 16:52:48.499 [main] INFO o.a.cassandra.cql3.QueryProcessor - Initialized prepared statement caches with 10 MB (native) and 10 MB (Thrift) 16:52:48.670 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2ca26d77[cfId=abac5682-dea6-31c5-b535-b3d6cffd0fb6,ksName=system_schema,cfName=keyspaces,flags=[COMPOUND],params=TableParams{comment=keyspace definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [durable_writes replication]],partitionKeyColumns=[keyspace_name],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[replication, keyspace_name, durable_writes],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.676 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@1b410b60[cfId=afddfb9d-bc1e-3068-8056-eed6c302ba09,ksName=system_schema,cfName=tables,flags=[COMPOUND],params=TableParams{comment=table definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [bloom_filter_fp_chance caching cdc comment compaction compression crc_check_chance dclocal_read_repair_chance default_time_to_live extensions flags gc_grace_seconds id max_index_interval memtable_flush_period_in_ms min_index_interval read_repair_chance speculative_retry]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[cdc, dclocal_read_repair_chance, gc_grace_seconds, speculative_retry, id, memtable_flush_period_in_ms, default_time_to_live, min_index_interval, bloom_filter_fp_chance, compression, caching, crc_check_chance, compaction, comment, keyspace_name, read_repair_chance, table_name, extensions, max_index_interval, flags],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.677 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@19b843ba[cfId=24101c25-a2ae-3af7-87c1-b40ee1aca33f,ksName=system_schema,cfName=columns,flags=[COMPOUND],params=TableParams{comment=column definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [clustering_order column_name_bytes kind position type]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name, column_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[kind, clustering_order, column_name_bytes, position, keyspace_name, table_name, type, column_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.677 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@77659b30[cfId=4df70b66-6b05-3251-95a1-32b54005fd48,ksName=system_schema,cfName=triggers,flags=[COMPOUND],params=TableParams{comment=trigger definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [options]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name, trigger_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[table_name, options, keyspace_name, trigger_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.678 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@1ec9bd38[cfId=5e7583b5-f3f4-3af1-9a39-b7e1d6f5f11f,ksName=system_schema,cfName=dropped_columns,flags=[COMPOUND],params=TableParams{comment=dropped column registry, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [dropped_time type]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name, column_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[table_name, type, keyspace_name, column_name, dropped_time],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.679 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@6b0d80ed[cfId=9786ac1c-dd58-3201-a7cd-ad556410c985,ksName=system_schema,cfName=views,flags=[COMPOUND],params=TableParams{comment=view definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [base_table_id base_table_name bloom_filter_fp_chance caching cdc comment compaction compression crc_check_chance dclocal_read_repair_chance default_time_to_live extensions gc_grace_seconds id include_all_columns max_index_interval memtable_flush_period_in_ms min_index_interval read_repair_chance speculative_retry where_clause]],partitionKeyColumns=[keyspace_name],clusteringColumns=[view_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[cdc, dclocal_read_repair_chance, gc_grace_seconds, speculative_retry, base_table_name, id, memtable_flush_period_in_ms, default_time_to_live, where_clause, min_index_interval, view_name, bloom_filter_fp_chance, compression, caching, crc_check_chance, compaction, base_table_id, comment, keyspace_name, read_repair_chance, include_all_columns, extensions, max_index_interval],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.680 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@928763c[cfId=5a8b1ca8-6602-3f77-a045-9273d308917a,ksName=system_schema,cfName=types,flags=[COMPOUND],params=TableParams{comment=user defined type definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [field_names field_types]],partitionKeyColumns=[keyspace_name],clusteringColumns=[type_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[field_names, type_name, field_types, keyspace_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.680 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@15f47664[cfId=96489b79-80be-3e14-a701-66a0b9159450,ksName=system_schema,cfName=functions,flags=[COMPOUND],params=TableParams{comment=user defined function definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.FrozenType(org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type))),partitionColumns=[[] | [argument_names body called_on_null_input language return_type]],partitionKeyColumns=[keyspace_name],clusteringColumns=[function_name, argument_types],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[function_name, keyspace_name, argument_names, return_type, body, argument_types, called_on_null_input, language],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.681 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@19976a65[cfId=924c5587-2e3a-345b-b10c-12f37c1ba895,ksName=system_schema,cfName=aggregates,flags=[COMPOUND],params=TableParams{comment=user defined aggregate definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.FrozenType(org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type))),partitionColumns=[[] | [final_func initcond return_type state_func state_type]],partitionKeyColumns=[keyspace_name],clusteringColumns=[aggregate_name, argument_types],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[final_func, aggregate_name, initcond, state_func, keyspace_name, return_type, state_type, argument_types],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.682 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@4b2c5e02[cfId=0feb57ac-311f-382f-ba6d-9024d305702f,ksName=system_schema,cfName=indexes,flags=[COMPOUND],params=TableParams{comment=secondary index definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=604800, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [kind options]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name, index_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[kind, table_name, options, keyspace_name, index_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.724 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@275bf9b3[cfId=9f5c6374-d485-3229-9a0a-5094af9ad1e3,ksName=system,cfName=IndexInfo,flags=[DENSE],params=TableParams{comment=built column indexes, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [value]],partitionKeyColumns=[table_name],clusteringColumns=[index_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[table_name, index_name, value],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.725 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@12a94400[cfId=919a4bc5-7a33-3573-b03e-13fc3f68b465,ksName=system,cfName=batches,flags=[COMPOUND],params=TableParams{comment=batches awaiting replay, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=2, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [version mutations]],partitionKeyColumns=[id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.TimeUUIDType,columnMetadata=[mutations, version, id],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.725 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2049a9c1[cfId=b7b7f0c2-fd0a-3410-8c05-3ef614bb7c2d,ksName=system,cfName=paxos,flags=[COMPOUND],params=TableParams{comment=in-progress paxos proposals, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.LeveledCompactionStrategy, options={}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UUIDType),partitionColumns=[[] | [in_progress_ballot most_recent_commit most_recent_commit_at most_recent_commit_version proposal proposal_ballot proposal_version]],partitionKeyColumns=[row_key],clusteringColumns=[cf_id],keyValidator=org.apache.cassandra.db.marshal.BytesType,columnMetadata=[cf_id, most_recent_commit_version, proposal, row_key, proposal_ballot, most_recent_commit_at, proposal_version, in_progress_ballot, most_recent_commit],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.726 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@7c51f34b[cfId=7ad54392-bcdd-35a6-8417-4e047860b377,ksName=system,cfName=local,flags=[COMPOUND],params=TableParams{comment=information about the local node, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [bootstrapped broadcast_address cluster_name cql_version data_center gossip_generation host_id listen_address native_protocol_version partitioner rack release_version rpc_address schema_version thrift_version tokens truncated_at]],partitionKeyColumns=[key],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[cql_version, tokens, bootstrapped, broadcast_address, listen_address, rack, release_version, cluster_name, native_protocol_version, thrift_version, rpc_address, truncated_at, schema_version, key, gossip_generation, data_center, partitioner, host_id],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.726 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2a225dd7[cfId=37f71aca-7dc2-383b-a706-72528af04d4f,ksName=system,cfName=peers,flags=[COMPOUND],params=TableParams{comment=information about known peers in the cluster, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [data_center host_id preferred_ip rack release_version rpc_address schema_version tokens]],partitionKeyColumns=[peer],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.InetAddressType,columnMetadata=[rpc_address, schema_version, preferred_ip, tokens, rack, release_version, peer, data_center, host_id],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.727 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@6fa34d52[cfId=59dfeaea-8db2-3341-91ef-109974d81484,ksName=system,cfName=peer_events,flags=[COMPOUND],params=TableParams{comment=events related to peers, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [hints_dropped]],partitionKeyColumns=[peer],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.InetAddressType,columnMetadata=[peer, hints_dropped],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.727 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@616ac46a[cfId=55d76438-4e55-3f8b-9f6e-676d4af3976d,ksName=system,cfName=range_xfers,flags=[COMPOUND],params=TableParams{comment=ranges requested for transfer, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [requested_at]],partitionKeyColumns=[token_bytes],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.BytesType,columnMetadata=[token_bytes, requested_at],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.728 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@7ef27d7f[cfId=b4dbb7b4-dc49-3fb5-b3bf-ce6e434832ca,ksName=system,cfName=compaction_history,flags=[COMPOUND],params=TableParams{comment=week-long compaction history, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=604800, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [bytes_in bytes_out columnfamily_name compacted_at keyspace_name rows_merged]],partitionKeyColumns=[id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UUIDType,columnMetadata=[bytes_out, id, keyspace_name, rows_merged, compacted_at, bytes_in, columnfamily_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.728 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@5c669da8[cfId=5a1ff267-ace0-3f12-8563-cfae6103c65e,ksName=system,cfName=sstable_activity,flags=[COMPOUND],params=TableParams{comment=historic sstable read rates, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [rate_120m rate_15m]],partitionKeyColumns=[keyspace_name, columnfamily_name, generation],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.CompositeType(org.apache.cassandra.db.marshal.UTF8Type,org.apache.cassandra.db.marshal.UTF8Type,org.apache.cassandra.db.marshal.Int32Type),columnMetadata=[generation, rate_120m, rate_15m, keyspace_name, columnfamily_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.729 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@1d483de4[cfId=618f817b-005f-3678-b8a4-53f3930b8e86,ksName=system,cfName=size_estimates,flags=[COMPOUND],params=TableParams{comment=per-table primary range size estimates, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [mean_partition_size partitions_count]],partitionKeyColumns=[keyspace_name],clusteringColumns=[table_name, range_start, range_end],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[range_start, table_name, mean_partition_size, keyspace_name, partitions_count, range_end],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.729 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@934b6cb[cfId=c539fcab-d65a-31d1-8133-d25605643ee3,ksName=system,cfName=available_ranges,flags=[COMPOUND],params=TableParams{comment=available keyspace/ranges during bootstrap/replace that are ready to be served, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [ranges]],partitionKeyColumns=[keyspace_name],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[ranges, keyspace_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.730 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@27adc16e[cfId=6cad20f7-d4f5-3af2-b6e2-0da33c6c1f83,ksName=system,cfName=transferred_ranges,flags=[COMPOUND],params=TableParams{comment=record of transferred ranges for streaming operation, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.InetAddressType),partitionColumns=[[] | [ranges]],partitionKeyColumns=[operation, keyspace_name],clusteringColumns=[peer],keyValidator=org.apache.cassandra.db.marshal.CompositeType(org.apache.cassandra.db.marshal.UTF8Type,org.apache.cassandra.db.marshal.UTF8Type),columnMetadata=[ranges, peer, operation, keyspace_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.730 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2609b277[cfId=b7f2c108-78cd-3c80-9cd5-d609b2bd149c,ksName=system,cfName=views_builds_in_progress,flags=[COMPOUND],params=TableParams{comment=views builds current progress, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [generation_number last_token]],partitionKeyColumns=[keyspace_name],clusteringColumns=[view_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[view_name, generation_number, keyspace_name, last_token],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.731 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@563e4951[cfId=4b3c50a9-ea87-3d76-9101-6dbc9c38494a,ksName=system,cfName=built_views,flags=[COMPOUND],params=TableParams{comment=built views, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [status_replicated]],partitionKeyColumns=[keyspace_name],clusteringColumns=[view_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[view_name, keyspace_name, status_replicated],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.731 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2b175c00[cfId=2666e205-73ef-38b3-90fe-fecf96e8f0c7,ksName=system,cfName=hints,flags=[DENSE, COMPOUND],params=TableParams{comment=*DEPRECATED* hints awaiting delivery, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32, enabled=false}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.TimeUUIDType, org.apache.cassandra.db.marshal.Int32Type),partitionColumns=[[] | [mutation]],partitionKeyColumns=[target_id],clusteringColumns=[hint_id, message_version],keyValidator=org.apache.cassandra.db.marshal.UUIDType,columnMetadata=[target_id, hint_id, mutation, message_version],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.732 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@1ae8bcbc[cfId=0290003c-977e-397c-ac3e-fdfdc01d626b,ksName=system,cfName=batchlog,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* batchlog entries, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=2, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [data version written_at]],partitionKeyColumns=[id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UUIDType,columnMetadata=[version, data, id, written_at],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.732 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@7d3d101b[cfId=18a9c257-6a0c-3841-ba71-8cd529849fef,ksName=system,cfName=prepared_statements,flags=[COMPOUND],params=TableParams{comment=prepared statements, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [logged_keyspace query_string]],partitionKeyColumns=[prepared_id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.BytesType,columnMetadata=[logged_keyspace, prepared_id, query_string],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.733 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@6d026701[cfId=b0f22357-4458-3cdb-9631-c43e59ce3676,ksName=system,cfName=schema_keyspaces,flags=[],params=TableParams{comment=*DEPRECATED* keyspace definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[durable_writes strategy_class strategy_options] | [value]],partitionKeyColumns=[keyspace_name],clusteringColumns=[column1],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[value, durable_writes, strategy_options, column1, strategy_class, keyspace_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.733 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@35399441[cfId=45f5b360-24bc-3f83-a363-1034ea4fa697,ksName=system,cfName=schema_columnfamilies,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* table definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [bloom_filter_fp_chance caching cf_id comment compaction_strategy_class compaction_strategy_options comparator compression_parameters default_time_to_live default_validator gc_grace_seconds is_dense key_validator local_read_repair_chance max_compaction_threshold max_index_interval memtable_flush_period_in_ms min_compaction_threshold min_index_interval read_repair_chance speculative_retry subcomparator type dropped_columns]],partitionKeyColumns=[keyspace_name],clusteringColumns=[columnfamily_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[memtable_flush_period_in_ms, min_compaction_threshold, default_time_to_live, min_index_interval, key_validator, is_dense, compaction_strategy_options, compaction_strategy_class, max_compaction_threshold, comment, compression_parameters, dropped_columns, max_index_interval, gc_grace_seconds, speculative_retry, local_read_repair_chance, bloom_filter_fp_chance, caching, default_validator, cf_id, keyspace_name, comparator, subcomparator, read_repair_chance, type, columnfamily_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.734 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@6304101a[cfId=296e9c04-9bec-3085-827d-c17d3df2122a,ksName=system,cfName=schema_columns,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* column definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [component_index index_name index_options index_type type validator]],partitionKeyColumns=[keyspace_name],clusteringColumns=[columnfamily_name, column_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[validator, component_index, keyspace_name, index_options, type, index_type, index_name, columnfamily_name, column_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.734 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@df6620a[cfId=0359bc71-7123-3ee1-9a4a-b9dfb11fc125,ksName=system,cfName=schema_triggers,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* trigger definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [trigger_options]],partitionKeyColumns=[keyspace_name],clusteringColumns=[columnfamily_name, trigger_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[trigger_options, keyspace_name, columnfamily_name, trigger_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.735 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@27d5a580[cfId=3aa75225-4f82-350b-8d5c-430fa221fa0a,ksName=system,cfName=schema_usertypes,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* user defined type definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [field_names field_types]],partitionKeyColumns=[keyspace_name],clusteringColumns=[type_name],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[field_names, type_name, field_types, keyspace_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.735 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@5e403b4a[cfId=d1b675fe-2b50-3ca4-8e49-c0f81989dcad,ksName=system,cfName=schema_functions,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* user defined function definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.FrozenType(org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type))),partitionColumns=[[] | [body called_on_null_input language return_type argument_names argument_types]],partitionKeyColumns=[keyspace_name],clusteringColumns=[function_name, signature],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[function_name, signature, keyspace_name, return_type, argument_names, body, argument_types, called_on_null_input, language],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.735 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@5be49b60[cfId=a5fc57fc-9d6c-3bfd-a3fc-01ad54686fea,ksName=system,cfName=schema_aggregates,flags=[COMPOUND],params=TableParams{comment=*DEPRECATED* user defined aggregate definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={min_threshold=4, max_threshold=32}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type, org.apache.cassandra.db.marshal.FrozenType(org.apache.cassandra.db.marshal.ListType(org.apache.cassandra.db.marshal.UTF8Type))),partitionColumns=[[] | [final_func initcond return_type state_func state_type argument_types]],partitionKeyColumns=[keyspace_name],clusteringColumns=[aggregate_name, signature],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[final_func, aggregate_name, signature, initcond, state_func, keyspace_name, return_type, state_type, argument_types],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:48.803 [main] DEBUG org.apache.cassandra.db.Keyspace - New replication settings for keyspace system_schema - invalidating disk boundary caches 16:52:48.917 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.keyspaces 16:52:48.939 [SSTableBatchOpen:1] INFO o.a.c.utils.memory.BufferPool - Global buffer pool is enabled, when pool is exhausted (max is 274.000MiB) it will allocate on heap 16:52:48.948 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/keyspaces-abac5682dea631c5b535b3d6cffd0fb6/md-6-big (0.124KiB) 16:52:48.948 [SSTableBatchOpen:2] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/keyspaces-abac5682dea631c5b535b3d6cffd0fb6/md-5-big (0.280KiB) 16:52:49.053 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.keyspaces 16:52:49.056 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.057 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.keyspaces 16:52:49.067 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.tables 16:52:49.070 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/tables-afddfb9dbc1e30688056eed6c302ba09/md-5-big (2.795KiB) 16:52:49.072 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.tables 16:52:49.072 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.072 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.tables 16:52:49.077 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.columns 16:52:49.082 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/columns-24101c25a2ae3af787c1b40ee1aca33f/md-3-big (0.229KiB) 16:52:49.082 [SSTableBatchOpen:2] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/columns-24101c25a2ae3af787c1b40ee1aca33f/md-2-big (0.229KiB) 16:52:49.084 [SSTableBatchOpen:3] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/columns-24101c25a2ae3af787c1b40ee1aca33f/md-1-big (5.646KiB) 16:52:49.085 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.columns 16:52:49.086 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.086 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.columns 16:52:49.090 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.triggers 16:52:49.093 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/triggers-4df70b666b05325195a132b54005fd48/md-1-big (0.050KiB) 16:52:49.094 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.triggers 16:52:49.094 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.094 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.triggers 16:52:49.101 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.dropped_columns 16:52:49.103 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/dropped_columns-5e7583b5f3f43af19a39b7e1d6f5f11f/md-1-big (0.050KiB) 16:52:49.104 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.dropped_columns 16:52:49.105 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.105 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.dropped_columns 16:52:49.109 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.views 16:52:49.111 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/views-9786ac1cdd583201a7cdad556410c985/md-1-big (0.050KiB) 16:52:49.113 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.views 16:52:49.113 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.113 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.views 16:52:49.117 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.types 16:52:49.119 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/types-5a8b1ca866023f77a0459273d308917a/md-1-big (0.050KiB) 16:52:49.120 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.types 16:52:49.120 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.120 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.types 16:52:49.124 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.functions 16:52:49.127 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/functions-96489b7980be3e14a70166a0b9159450/md-1-big (0.050KiB) 16:52:49.128 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.functions 16:52:49.128 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.128 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.functions 16:52:49.132 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.aggregates 16:52:49.134 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/aggregates-924c55872e3a345bb10c12f37c1ba895/md-1-big (0.050KiB) 16:52:49.135 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.aggregates 16:52:49.135 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.135 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.aggregates 16:52:49.139 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.indexes 16:52:49.141 [SSTableBatchOpen:1] DEBUG o.a.c.i.sstable.format.SSTableReader - Opening /var/lib/cassandra/data/system_schema/indexes-0feb57ac311f382fba6d9024d305702f/md-1-big (0.050KiB) 16:52:49.142 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.indexes 16:52:49.142 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:52:49.142 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Updating boundaries from null to DiskBoundaries{directories=[DataDirectory{location=/var/lib/cassandra/data}], positions=null, ringVersion=0, directoriesVersion=0} for system_schema.indexes 16:52:49.143 [main] INFO o.a.cassandra.db.view.ViewManager - Not submitting build tasks for views in keyspace system_schema as storage service is not initialized 16:52:49.190 [main] INFO o.a.c.db.monitoring.ApproximateTime - Scheduling approximate time-check task with a precision of 10 milliseconds 16:52:49.294 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@22c01ab0[cfId=5f2fbdad-91f1-3946-bd25-d5da3a5c35ec,ksName=system_auth,cfName=resource_role_permissons_index,flags=[COMPOUND],params=TableParams{comment=index of db roles with permissions granted on a resource, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=7776000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | []],partitionKeyColumns=[resource],clusteringColumns=[role],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[resource, role],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.294 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@4c4d362a[cfId=0ecdaa87-f8fb-3e60-88d1-74fb36fe5c0d,ksName=system_auth,cfName=role_members,flags=[COMPOUND],params=TableParams{comment=role memberships lookup table, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=7776000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | []],partitionKeyColumns=[role],clusteringColumns=[member],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[role, member],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.295 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@76b74e9c[cfId=3afbe79f-2194-31a7-add7-f5ab90d8ec9c,ksName=system_auth,cfName=role_permissions,flags=[COMPOUND],params=TableParams{comment=permissions granted to db roles, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=7776000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[] | [permissions]],partitionKeyColumns=[role],clusteringColumns=[resource],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[role, resource, permissions],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.295 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@8ab78bc[cfId=5bc52802-de25-35ed-aeab-188eecebb090,ksName=system_auth,cfName=roles,flags=[COMPOUND],params=TableParams{comment=role definitions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=7776000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [can_login is_superuser salted_hash member_of]],partitionKeyColumns=[role],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UTF8Type,columnMetadata=[salted_hash, member_of, role, can_login, is_superuser],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.295 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@16afbd92[cfId=5cabd870-8001-11ea-9779-8d4dee7ae69d,ksName=keyspace1,cfName=counter1,flags=[COUNTER],params=TableParams{comment=, read_repair_chance=0.0, dclocal_read_repair_chance=0.1, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=864000, default_time_to_live=0, memtable_flush_period_in_ms=0, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@8690cab1, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[C0 C1 C2 C3 C4] | [value]],partitionKeyColumns=[key],clusteringColumns=[column1],keyValidator=org.apache.cassandra.db.marshal.BytesType,columnMetadata=[C4, C3, C2, C1, column1, C0, value, key],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.296 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@7fe083b1[cfId=5bfd48f0-8001-11ea-9779-8d4dee7ae69d,ksName=keyspace1,cfName=standard1,flags=[],params=TableParams{comment=, read_repair_chance=0.0, dclocal_read_repair_chance=0.1, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=864000, default_time_to_live=0, memtable_flush_period_in_ms=0, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@8690cab1, extensions={}, cdc=true},comparator=comparator(org.apache.cassandra.db.marshal.UTF8Type),partitionColumns=[[C0 C1 C2 C3 C4] | [value]],partitionKeyColumns=[key],clusteringColumns=[column1],keyValidator=org.apache.cassandra.db.marshal.BytesType,columnMetadata=[C4, C3, C2, C1, column1, C0, value, key],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.296 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@486be205[cfId=deabd734-b99d-3b9c-92e5-fd92eb5abf14,ksName=system_distributed,cfName=parent_repair_history,flags=[COMPOUND],params=TableParams{comment=Repair history, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=864000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [exception_message exception_stacktrace finished_at keyspace_name started_at columnfamily_names options requested_ranges successful_ranges]],partitionKeyColumns=[parent_id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.TimeUUIDType,columnMetadata=[requested_ranges, exception_message, keyspace_name, successful_ranges, started_at, finished_at, options, exception_stacktrace, parent_id, columnfamily_names],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.296 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@4b4dd216[cfId=759fffad-624b-3181-80ee-fa9a52d1f627,ksName=system_distributed,cfName=repair_history,flags=[COMPOUND],params=TableParams{comment=Repair history, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=864000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.TimeUUIDType),partitionColumns=[[] | [coordinator coordinator_port exception_message exception_stacktrace finished_at parent_id range_begin range_end started_at status participants participants_v2]],partitionKeyColumns=[keyspace_name, columnfamily_name],clusteringColumns=[id],keyValidator=org.apache.cassandra.db.marshal.CompositeType(org.apache.cassandra.db.marshal.UTF8Type,org.apache.cassandra.db.marshal.UTF8Type),columnMetadata=[status, id, coordinator_port, coordinator, finished_at, participants_v2, participants, exception_stacktrace, parent_id, range_end, range_begin, exception_message, keyspace_name, started_at, columnfamily_name],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.297 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@5a62b2a4[cfId=5582b59f-8e4e-35e1-b913-3acada51eb04,ksName=system_distributed,cfName=view_build_status,flags=[COMPOUND],params=TableParams{comment=Materialized View build status, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=864000, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.UUIDType),partitionColumns=[[] | [status]],partitionKeyColumns=[keyspace_name, view_name],clusteringColumns=[host_id],keyValidator=org.apache.cassandra.db.marshal.CompositeType(org.apache.cassandra.db.marshal.UTF8Type,org.apache.cassandra.db.marshal.UTF8Type),columnMetadata=[view_name, status, keyspace_name, host_id],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.298 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@35293c05[cfId=8826e8e9-e16a-3728-8753-3bc1fc713c25,ksName=system_traces,cfName=events,flags=[COMPOUND],params=TableParams{comment=tracing events, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(org.apache.cassandra.db.marshal.TimeUUIDType),partitionColumns=[[] | [activity source source_elapsed source_port thread]],partitionKeyColumns=[session_id],clusteringColumns=[event_id],keyValidator=org.apache.cassandra.db.marshal.UUIDType,columnMetadata=[activity, session_id, thread, event_id, source_port, source, source_elapsed],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.298 [main] DEBUG org.apache.cassandra.config.Schema - Adding org.apache.cassandra.config.CFMetaData@2db2dd9d[cfId=c5e99f16-8677-3914-b17e-960613512345,ksName=system_traces,cfName=sessions,flags=[COMPOUND],params=TableParams{comment=tracing sessions, read_repair_chance=0.0, dclocal_read_repair_chance=0.0, bloom_filter_fp_chance=0.01, crc_check_chance=1.0, gc_grace_seconds=0, default_time_to_live=0, memtable_flush_period_in_ms=3600000, min_index_interval=128, max_index_interval=2048, speculative_retry=99PERCENTILE, caching={'keys' : 'ALL', 'rows_per_partition' : 'NONE'}, compaction=CompactionParams{class=org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy, options={max_threshold=32, min_threshold=4}}, compression=org.apache.cassandra.schema.CompressionParams@f70fe086, extensions={}, cdc=false},comparator=comparator(),partitionColumns=[[] | [client command coordinator coordinator_port duration request started_at parameters]],partitionKeyColumns=[session_id],clusteringColumns=[],keyValidator=org.apache.cassandra.db.marshal.UUIDType,columnMetadata=[client, command, session_id, coordinator_port, coordinator, request, started_at, duration, parameters],droppedColumns={},triggers=[],indexes=[]] to cfIdMap 16:52:49.301 [main] INFO com.datastax.driver.core - DataStax Java driver 3.5.0 for Apache Cassandra 16:52:49.307 [main] DEBUG c.d.driver.core.GuavaCompatibility - Error while checking existence of method Futures.transformAsync java.lang.NoSuchMethodException: com.google.common.util.concurrent.Futures.transformAsync(com.google.common.util.concurrent.ListenableFuture, com.google.common.util.concurrent.AsyncFunction) at java.lang.Class.getMethod(Class.java:1786) ~[na:1.8.0_242] at com.datastax.driver.core.GuavaCompatibility.methodExists(GuavaCompatibility.java:253) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at com.datastax.driver.core.GuavaCompatibility.isGuava_19_0_OrHigher(GuavaCompatibility.java:225) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at com.datastax.driver.core.GuavaCompatibility.selectImplementation(GuavaCompatibility.java:131) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at com.datastax.driver.core.GuavaCompatibility.(GuavaCompatibility.java:52) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at com.datastax.driver.core.Cluster.(Cluster.java:71) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at io.debezium.connector.cassandra.CassandraClient.(CassandraClient.java:53) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at io.debezium.connector.cassandra.CassandraClient.(CassandraClient.java:48) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at io.debezium.connector.cassandra.CassandraConnectorContext.(CassandraConnectorContext.java:39) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at io.debezium.connector.cassandra.CassandraConnectorTask.run(CassandraConnectorTask.java:72) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] at io.debezium.connector.cassandra.CassandraConnectorTask.main(CassandraConnectorTask.java:61) [debezium-connector-cassandra-1.1.0.Final-jar-with-dependencies.jar:1.1.0.Final] 16:52:49.316 [main] INFO c.d.driver.core.GuavaCompatibility - Detected Guava < 19 in the classpath, using legacy compatibility layer 16:52:49.317 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NEW_NODE_DELAY_SECONDS is undefined, using default value 1 16:52:49.317 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NOTIF_LOCK_TIMEOUT_SECONDS is undefined, using default value 60 16:52:49.327 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.USE_NATIVE_CLOCK is undefined, using default value true 16:52:49.441 [main] INFO c.datastax.driver.core.ClockFactory - Using native clock to generate timestamps. 16:52:49.444 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NON_BLOCKING_EXECUTOR_SIZE is undefined, using default value 6 16:52:49.462 [main] DEBUG com.datastax.driver.core.Cluster - Starting new cluster with contact points [cassandra-seed/172.21.0.5:9042] 16:52:49.472 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework 16:52:49.480 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false 16:52:49.481 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available 16:52:49.482 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available 16:52:49.482 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available 16:52:49.482 [main] DEBUG i.n.util.internal.PlatformDependent0 - direct buffer constructor: available 16:52:49.483 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: available, true 16:52:49.483 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.DirectByteBuffer.(long, int): available 16:52:49.483 [main] DEBUG io.netty.util.internal.Cleaner0 - java.nio.ByteBuffer.cleaner(): available 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - You don't have Javassist in your class path or you don't have enough permission to load dynamically generated classes. Please check the configuration for better performance. 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model) 16:52:49.484 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false 16:52:49.485 [main] DEBUG i.n.util.internal.PlatformDependent - io.netty.maxDirectMemory: 1152385024 bytes 16:52:49.488 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FORCE_NIO is undefined, using default value false 16:52:49.490 [main] DEBUG i.n.u.internal.NativeLibraryLoader - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 16:52:49.490 [main] DEBUG i.n.u.internal.NativeLibraryLoader - -Dio.netty.native.workdir: /tmp (io.netty.tmpdir) 16:52:49.497 [main] DEBUG io.netty.util.NetUtil - Loopback interface: lo (lo, 127.0.0.1) 16:52:49.497 [main] DEBUG io.netty.util.NetUtil - /proc/sys/net/core/somaxconn: 128 16:52:49.498 [main] INFO com.datastax.driver.core.NettyUtil - Found Netty's native epoll transport in the classpath, using it 16:52:49.507 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 12 16:52:49.513 [main] DEBUG i.n.util.internal.PlatformDependent - org.jctools-core.MpscChunkedArrayQueue: available 16:52:49.527 [main] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetection.level: simple 16:52:49.527 [main] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetection.maxRecords: 4 16:52:49.527 [main] DEBUG i.n.util.ResourceLeakDetectorFactory - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@79767781 16:52:49.529 [main] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0x260f28f8f367e110 (took 0 ms) 16:52:49.531 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.EXTENDED_PEER_CHECK is undefined, using default value true 16:52:49.538 [main] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] preparing to open 1 new connections, total = 1 16:52:49.540 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.DISABLE_COALESCING is undefined, using default value false 16:52:49.540 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FLUSHER_SCHEDULE_PERIOD_NS is undefined, using default value 10000 16:52:49.540 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FLUSHER_RUN_WITHOUT_WORK_TIMES is undefined, using default value 5 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 11 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 11 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216 16:52:49.553 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512 16:52:49.554 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256 16:52:49.554 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64 16:52:49.554 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 16:52:49.554 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192 16:52:49.554 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.useCacheForAllThreads: true 16:52:49.574 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled 16:52:49.574 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 65536 16:52:49.574 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.maxThreadLocalCharBufferSize: 16384 16:52:49.588 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] Connection established, initializing transport 16:52:49.598 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 32768 16:52:49.598 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxSharedCapacityFactor: 2 16:52:49.598 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.linkCapacity: 16 16:52:49.598 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.ratio: 8 16:52:49.609 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf - -Dio.netty.buffer.bytebuf.checkAccessible: true 16:52:49.609 [cluster1-nio-worker-0] DEBUG i.n.util.ResourceLeakDetectorFactory - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@6b8fd04e 16:52:49.615 [cluster1-nio-worker-0] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NATIVE_TRANSPORT_MAX_FRAME_SIZE_IN_MB is undefined, using default value 256 16:52:49.616 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] Transport initialized, connection ready 16:52:49.617 [main] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing node list and token map 16:52:49.652 [main] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema 16:52:49.737 [main] DEBUG com.datastax.driver.core.Host.STATES - [Control connection] established to cassandra-seed/172.21.0.5:9042 16:52:49.737 [main] INFO c.d.d.c.p.DCAwareRoundRobinPolicy - Using data-center name 'datacenter1' for DCAwareRoundRobinPolicy (if this is incorrect, please provide the correct datacenter name with DCAwareRoundRobinPolicy constructor) 16:52:49.738 [main] INFO com.datastax.driver.core.Cluster - New Cassandra host cassandra-seed/172.21.0.5:9042 added 16:52:49.740 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.CHECK_IO_DEADLOCKS is undefined, using default value true 16:52:49.741 [main] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] preparing to open 1 new connections, total = 2 16:52:49.742 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] Connection established, initializing transport 16:52:49.748 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] Transport initialized, connection ready 16:52:49.749 [cluster1-nio-worker-2] DEBUG c.d.driver.core.HostConnectionPool - Created connection pool to host cassandra-seed/172.21.0.5:9042 (1 connections needed, 1 successfully opened) 16:52:49.749 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Session - Added connection pool for cassandra-seed/172.21.0.5:9042 16:52:49.752 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:52:49.759 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:52:49.759 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:52:49.761 [main] INFO i.d.c.c.CassandraConnectorTask - Starting processor group ... 16:52:49.823 [main] INFO i.c.connect.avro.AvroConverterConfig - AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.914 [main] INFO i.c.k.s.KafkaAvroSerializerConfig - KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.916 [main] INFO i.c.k.s.KafkaAvroDeserializerConfig - KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.954 [main] INFO i.c.connect.avro.AvroDataConfig - AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 16:52:49.956 [main] INFO i.c.connect.avro.AvroConverterConfig - AvroConverterConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.956 [main] INFO i.c.k.s.KafkaAvroSerializerConfig - KafkaAvroSerializerConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.956 [main] INFO i.c.k.s.KafkaAvroDeserializerConfig - KafkaAvroDeserializerConfig values: bearer.auth.token = [hidden] schema.registry.url = [http://schemaregistry:8081] basic.auth.user.info = [hidden] auto.register.schemas = true max.schemas.per.subject = 1000 basic.auth.credentials.source = URL schema.registry.basic.auth.user.info = [hidden] bearer.auth.credentials.source = STATIC_TOKEN specific.avro.reader = false value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy 16:52:49.956 [main] INFO i.c.connect.avro.AvroDataConfig - AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 16:52:49.966 [main] INFO o.a.k.c.producer.ProducerConfig - ProducerConfig values: acks = 1 batch.size = 16384 bootstrap.servers = [kafka1:9092] buffer.memory = 33554432 client.dns.lookup = default client.id = compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 60000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 3 retry.backoff.ms = 1000 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = https ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 16:52:49.977 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 16:52:49.979 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 16:52:49.982 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 16:52:49.987 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 16:52:49.993 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 16:52:49.993 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-authentication: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-reauthentication: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-authentication-no-reauth: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name failed-authentication: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name failed-reauthentication: 16:52:49.994 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name reauthentication-latency: 16:52:49.995 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 16:52:49.995 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 16:52:49.995 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 16:52:49.995 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 16:52:49.996 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 16:52:49.999 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 16:52:50.000 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size 16:52:50.001 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-split-rate 16:52:50.001 [kafka-producer-network-thread | producer-1] DEBUG o.a.k.c.producer.internals.Sender - [Producer clientId=producer-1] Starting Kafka producer I/O thread. 16:52:50.002 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version: 2.4.0 16:52:50.002 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId: 77a89fcf8d7fa018 16:52:50.002 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1587055970001 16:52:50.003 [main] DEBUG o.a.k.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer started 16:52:50.005 [main] INFO i.d.c.c.CassandraConnectorTask - Starting processor group Cassandra Connector Task 16:52:50.006 [pool-4-thread-1] INFO i.d.c.cassandra.AbstractProcessor - Started Change Event Queue Processor 16:52:50.006 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:52:50.007 [pool-4-thread-2] INFO i.d.c.cassandra.AbstractProcessor - Started Commit Log Processor 16:52:50.007 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Reading existing commit logs in /var/lib/cassandra/cdc_raw 16:52:50.007 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:50.008 [pool-4-thread-3] INFO i.d.c.cassandra.AbstractProcessor - Started Schema Processor 16:52:50.008 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:52:50.008 [main] INFO i.d.c.c.CassandraConnectorTask - Starting HTTP server ... 16:52:50.008 [main] INFO i.d.c.c.CassandraConnectorTask - HTTP port is 8000 16:52:50.008 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:52:50.008 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:52:50.010 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Processing commit log CommitLog-6-1587055325148.log 16:52:50.012 [pool-4-thread-4] INFO i.d.c.cassandra.AbstractProcessor - Started Commit Log Post-Processor 16:52:50.015 [pool-4-thread-5] INFO i.d.c.cassandra.AbstractProcessor - Started Snapshot Processor 16:52:50.020 [pool-4-thread-5] INFO i.d.c.cassandra.SnapshotProcessor - No tables to snapshot 16:52:50.020 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325148.log (CL version 6, messaging version 11, compression null) 16:52:50.020 [main] DEBUG org.eclipse.jetty.util.log - Logging to Logger[org.eclipse.jetty.util.log] via org.eclipse.jetty.util.log.Slf4jLog 16:52:50.022 [main] INFO org.eclipse.jetty.util.log - Logging initialized @2128ms to org.eclipse.jetty.util.log.Slf4jLog 16:52:50.044 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@687e4c93{STOPPED}[9.4.z-SNAPSHOT] added {QueuedThreadPool[qtp1291485735]@4cfa8227{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$201/409393797@278667fd],AUTO} 16:52:50.059 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - HttpConnectionFactory@19f7222e[HTTP/1.1] added {HttpConfiguration@3f725306{32768/8192,8192/8192,https://:0,[]},POJO} 16:52:50.060 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{null,[]}{0.0.0.0:0} added {Server@687e4c93{STOPPED}[9.4.z-SNAPSHOT],UNMANAGED} 16:52:50.060 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{null,[]}{0.0.0.0:0} added {QueuedThreadPool[qtp1291485735]@4cfa8227{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$201/409393797@278667fd],AUTO} 16:52:50.060 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{null,[]}{0.0.0.0:0} added {ScheduledExecutorScheduler@496a31da{STOPPED},AUTO} 16:52:50.060 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{null,[]}{0.0.0.0:0} added {org.eclipse.jetty.io.ArrayByteBufferPool@66f0548d,POJO} 16:52:50.061 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{null,[http/1.1]}{0.0.0.0:0} added {HttpConnectionFactory@19f7222e[HTTP/1.1],AUTO} 16:52:50.061 [main] DEBUG o.e.jetty.server.AbstractConnector - ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:0} added HttpConnectionFactory@19f7222e[HTTP/1.1] 16:52:50.063 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:0} added {SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:0},MANAGED} 16:52:50.063 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@687e4c93{STOPPED}[9.4.z-SNAPSHOT] added {ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000},AUTO} 16:52:50.073 [main] DEBUG o.e.j.util.DecoratedObjectFactory - Adding Decorator: org.eclipse.jetty.util.DeprecationWarning@2241f05b 16:52:50.077 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - o.e.j.s.ServletContextHandler@36a6bea6{/,null,UNAVAILABLE} added {org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1,MANAGED} 16:52:50.081 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 added {ServletHandler@858d8b4{STOPPED},MANAGED} 16:52:50.083 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@687e4c93{STOPPED}[9.4.z-SNAPSHOT] added {o.e.j.s.ServletContextHandler@36a6bea6{/,null,UNAVAILABLE},MANAGED} 16:52:50.089 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true,AUTO} 16:52:50.089 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {[/ping]=>com.codahale.metrics.servlets.PingServlet-6726cc69,POJO} 16:52:50.090 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true,AUTO} 16:52:50.090 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {[/buildinfo]=>io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca,POJO} 16:52:50.091 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true,AUTO} 16:52:50.091 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {[/metrics]=>com.codahale.metrics.servlets.MetricsServlet-2436ea2f,POJO} 16:52:50.092 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true,AUTO} 16:52:50.093 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STOPPED} added {[/health]=>com.codahale.metrics.servlets.HealthCheckServlet-64984b0f,POJO} 16:52:50.093 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting Server@687e4c93{STOPPED}[9.4.z-SNAPSHOT] 16:52:50.094 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@687e4c93{STARTING}[9.4.z-SNAPSHOT] added {ErrorHandler@5d5c04f9{STOPPED},AUTO} 16:52:50.095 [main] INFO org.eclipse.jetty.server.Server - jetty-9.4.z-SNAPSHOT; built: 2018-08-30T13:59:14.071Z; git: 27208684755d94a92186989f695db2d7b21ebc51; jvm 1.8.0_242-b08 16:52:50.107 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting Server@687e4c93{STARTING}[9.4.z-SNAPSHOT] 16:52:50.107 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting QueuedThreadPool[qtp1291485735]@4cfa8227{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$201/409393797@278667fd] 16:52:50.108 [main] DEBUG o.e.j.u.t.ReservedThreadExecutor - ReservedThreadExecutor@2d9dff65{s=0/6,p=0} 16:52:50.108 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - QueuedThreadPool[qtp1291485735]@4cfa8227{STARTING,8<=0<=200,i=0,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}] added {ReservedThreadExecutor@2d9dff65{s=0/6,p=0},AUTO} 16:52:50.108 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ReservedThreadExecutor@2d9dff65{s=0/6,p=0} 16:52:50.110 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2217ms ReservedThreadExecutor@2d9dff65{s=0/6,p=0} 16:52:50.122 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2228ms QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}] 16:52:50.122 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting o.e.j.s.ServletContextHandler@36a6bea6{/,null,UNAVAILABLE} 16:52:50.125 [main] DEBUG o.e.jetty.http.PreEncodedHttpField - HttpField encoders loaded: [org.eclipse.jetty.http.Http1FieldPreEncoder@1b1f5012] 16:52:50.131 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting o.e.j.s.ServletContextHandler@36a6bea6{/,null,STARTING} 16:52:50.131 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 16:52:50.134 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 added {org.eclipse.jetty.server.session.DefaultSessionCache@1229a2b7[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false],AUTO} 16:52:50.134 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.DefaultSessionCache@1229a2b7[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] added {org.eclipse.jetty.server.session.NullSessionDataStore@31ee2fdb[passivating=false,graceSec=3600],AUTO} 16:52:50.135 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting DefaultSessionIdManager@46c269e0{STOPPED}[worker=null] 16:52:50.135 [main] INFO org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0 16:52:50.135 [main] INFO org.eclipse.jetty.server.session - No SessionScavenger set, using defaults 16:52:50.136 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - DefaultSessionIdManager@46c269e0{STARTING}[worker=node0] added {HouseKeeper@5fa23c{STOPPED}[interval=600000, ownscheduler=false],MANAGED} 16:52:50.136 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting HouseKeeper@5fa23c{STOPPED}[interval=600000, ownscheduler=false] 16:52:50.136 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@558756be{STOPPED} 16:52:50.136 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2243ms ScheduledExecutorScheduler@558756be{STARTED} 16:52:50.136 [main] DEBUG org.eclipse.jetty.server.session - Using own scheduler for scavenging 16:52:50.137 [main] INFO org.eclipse.jetty.server.session - node0 Scavenging every 660000ms 16:52:50.138 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2244ms HouseKeeper@5fa23c{STARTED}[interval=660000, ownscheduler=true] 16:52:50.138 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2244ms DefaultSessionIdManager@46c269e0{STARTED}[worker=node0] 16:52:50.138 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@687e4c93{STARTING}[9.4.z-SNAPSHOT] added {DefaultSessionIdManager@46c269e0{STARTED}[worker=node0],MANAGED} 16:52:50.138 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 added {DefaultSessionIdManager@46c269e0{STARTED}[worker=node0],UNMANAGED} 16:52:50.138 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@2643d762{STOPPED} 16:52:50.138 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2245ms ScheduledExecutorScheduler@2643d762{STARTED} 16:52:50.139 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 16:52:50.139 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ServletHandler@858d8b4{STOPPED} 16:52:50.140 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/health[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f[EMBEDDED:null] 16:52:50.141 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/health",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true] to PathMappings[size=1] 16:52:50.141 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/buildinfo[EMBEDDED:null] mapped to servlet=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca[EMBEDDED:null] 16:52:50.141 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/buildinfo",pathDepth=1,group=EXACT],resource=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true] to PathMappings[size=2] 16:52:50.141 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/ping[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.PingServlet-6726cc69[EMBEDDED:null] 16:52:50.141 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/ping",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true] to PathMappings[size=3] 16:52:50.141 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/metrics[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.MetricsServlet-2436ea2f[EMBEDDED:null] 16:52:50.141 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/metrics",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true] to PathMappings[size=4] 16:52:50.141 [main] DEBUG o.e.jetty.servlet.ServletHandler - filterNameMap={} 16:52:50.142 [main] DEBUG o.e.jetty.servlet.ServletHandler - pathFilters=null 16:52:50.142 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletFilterMap=null 16:52:50.142 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletPathMap=PathMappings[size=4] 16:52:50.142 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletNameMap={com.codahale.metrics.servlets.PingServlet-6726cc69=com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.MetricsServlet-2436ea2f=com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true, io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.HealthCheckServlet-64984b0f=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true} 16:52:50.142 [main] DEBUG o.e.jetty.servlet.ServletHandler - Adding Default404Servlet to ServletHandler@858d8b4{STARTING} 16:52:50.142 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STARTING} added {org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5@22384702==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false,AUTO} 16:52:50.142 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@858d8b4{STARTING} added {[/]=>org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5,POJO} 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/health[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f[EMBEDDED:null] 16:52:50.143 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/health",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true] to PathMappings[size=1] 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/buildinfo[EMBEDDED:null] mapped to servlet=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca[EMBEDDED:null] 16:52:50.143 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/buildinfo",pathDepth=1,group=EXACT],resource=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true] to PathMappings[size=2] 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/ping[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.PingServlet-6726cc69[EMBEDDED:null] 16:52:50.143 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/ping",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true] to PathMappings[size=3] 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/metrics[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.MetricsServlet-2436ea2f[EMBEDDED:null] 16:52:50.143 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/metrics",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true] to PathMappings[size=4] 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/[EMBEDDED:null] mapped to servlet=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5[EMBEDDED:null] 16:52:50.143 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/",pathDepth=-1,group=DEFAULT],resource=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5@22384702==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false] to PathMappings[size=5] 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - filterNameMap={} 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - pathFilters=null 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletFilterMap=null 16:52:50.143 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletPathMap=PathMappings[size=5] 16:52:50.144 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletNameMap={com.codahale.metrics.servlets.PingServlet-6726cc69=com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.MetricsServlet-2436ea2f=com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true, io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca=io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true, org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5@22384702==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false, com.codahale.metrics.servlets.HealthCheckServlet-64984b0f=com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true} 16:52:50.144 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting ServletHandler@858d8b4{STARTING} 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2250ms ServletHandler@858d8b4{STARTED} 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.DefaultSessionCache@1229a2b7[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.NullSessionDataStore@31ee2fdb[passivating=false,graceSec=3600] 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2250ms org.eclipse.jetty.server.session.NullSessionDataStore@31ee2fdb[passivating=false,graceSec=3600] 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2250ms org.eclipse.jetty.server.session.DefaultSessionCache@1229a2b7[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2250ms org.eclipse.jetty.server.session.SessionHandler1156135967==dftMaxIdleSec=-1 16:52:50.144 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true 16:52:50.145 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2251ms com.codahale.metrics.servlets.HealthCheckServlet-64984b0f@b40bb7c6==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true 16:52:50.145 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.HealthCheckServlet@7aac8884 for com.codahale.metrics.servlets.HealthCheckServlet-64984b0f 16:52:50.148 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true 16:52:50.148 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2255ms com.codahale.metrics.servlets.MetricsServlet-2436ea2f@a3a5fb71==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true 16:52:50.149 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.MetricsServlet@5bc28f40 for com.codahale.metrics.servlets.MetricsServlet-2436ea2f 16:52:50.150 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true 16:52:50.151 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2257ms com.codahale.metrics.servlets.PingServlet-6726cc69@1d022d1==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true 16:52:50.151 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.PingServlet@625d9132 for com.codahale.metrics.servlets.PingServlet-6726cc69 16:52:50.151 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true 16:52:50.151 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2257ms io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca@9ea12c98==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true 16:52:50.151 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init io.debezium.connector.cassandra.network.BuildInfoServlet@77774571 for io.debezium.connector.cassandra.network.BuildInfoServlet-5292ceca 16:52:50.151 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5@22384702==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false 16:52:50.151 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2258ms org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-421056e5@22384702==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false 16:52:50.151 [main] INFO o.e.j.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@36a6bea6{/,null,AVAILABLE} 16:52:50.152 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2258ms o.e.j.s.ServletContextHandler@36a6bea6{/,null,AVAILABLE} 16:52:50.152 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ErrorHandler@5d5c04f9{STOPPED} 16:52:50.152 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting ErrorHandler@5d5c04f9{STARTING} 16:52:50.152 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2258ms ErrorHandler@5d5c04f9{STARTED} 16:52:50.152 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:52:50.156 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {sun.nio.ch.ServerSocketChannelImpl[/0.0.0.0:8000],POJO} 16:52:50.156 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@496a31da{STOPPED} 16:52:50.156 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2263ms ScheduledExecutorScheduler@496a31da{STARTED} 16:52:50.156 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting HttpConnectionFactory@19f7222e[HTTP/1.1] 16:52:50.156 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2263ms HttpConnectionFactory@19f7222e[HTTP/1.1] 16:52:50.157 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:52:50.164 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Finished reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325148.log 16:52:50.164 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.162Z added {SelectorProducer@6e0c6a7a,POJO} 16:52:50.164 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'io.debezium.connector.cassandra.EOFEvent@2692ab57' 16:52:50.164 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Successfully processed commit log CommitLog-6-1587055325148.log 16:52:50.164 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Processing commit log CommitLog-6-1587055325150.log 16:52:50.165 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.164Z added {QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}],UNMANAGED} 16:52:50.165 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325150.log (CL version 6, messaging version 11, compression null) 16:52:50.165 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.165Z created 16:52:50.165 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@c3edf4c{STOPPED} id=0 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.165Z,MANAGED} 16:52:50.165 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@c3edf4c{STOPPED} id=0 keys=-1 selected=-1 updates=0,AUTO} 16:52:50.166 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.166Z added {SelectorProducer@799ed4e8,POJO} 16:52:50.166 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.166Z added {QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}],UNMANAGED} 16:52:50.166 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.166Z created 16:52:50.167 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@2e66bc32{STOPPED} id=1 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.166Z,MANAGED} 16:52:50.167 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@2e66bc32{STOPPED} id=1 keys=-1 selected=-1 updates=0,AUTO} 16:52:50.167 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.167Z added {SelectorProducer@4b65d9f4,POJO} 16:52:50.167 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.167Z added {QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}],UNMANAGED} 16:52:50.167 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.167Z created 16:52:50.168 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@44536de4{STOPPED} id=2 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.167Z,MANAGED} 16:52:50.168 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@44536de4{STOPPED} id=2 keys=-1 selected=-1 updates=0,AUTO} 16:52:50.168 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@c3edf4c{STOPPED} id=0 keys=-1 selected=-1 updates=0 16:52:50.168 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.168Z 16:52:50.168 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2274ms EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.168Z 16:52:50.169 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@77b919a3 16:52:50.169 [qtp1291485735-61] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@77b919a3 16:52:50.169 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@5624657a on ManagedSelector@c3edf4c{STARTING} id=0 keys=0 selected=0 updates=0 16:52:50.170 [qtp1291485735-61] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@455c1d8c/SelectorProducer@6e0c6a7a/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.169Z tryProduce false 16:52:50.170 [qtp1291485735-61] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:52:50.171 [qtp1291485735-61] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@5624657a 16:52:50.171 [qtp1291485735-61] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:52:50.171 [qtp1291485735-61] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@659bc29a waiting with 0 keys 16:52:50.171 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2277ms ManagedSelector@c3edf4c{STARTED} id=0 keys=0 selected=0 updates=0 16:52:50.171 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@2e66bc32{STOPPED} id=1 keys=-1 selected=-1 updates=0 16:52:50.171 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.171Z 16:52:50.171 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2278ms EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.171Z 16:52:50.171 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@36681447 16:52:50.172 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@4d21c56e on ManagedSelector@2e66bc32{STARTING} id=1 keys=0 selected=0 updates=0 16:52:50.172 [qtp1291485735-62] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@36681447 16:52:50.172 [qtp1291485735-62] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@5af8bb51/SelectorProducer@799ed4e8/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.172Z tryProduce false 16:52:50.172 [qtp1291485735-62] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:52:50.172 [qtp1291485735-62] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@4d21c56e 16:52:50.172 [qtp1291485735-62] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:52:50.172 [qtp1291485735-62] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@7beb6be8 waiting with 0 keys 16:52:50.172 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2278ms ManagedSelector@2e66bc32{STARTED} id=1 keys=0 selected=0 updates=0 16:52:50.172 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@44536de4{STOPPED} id=2 keys=-1 selected=-1 updates=0 16:52:50.172 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.172Z 16:52:50.173 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2279ms EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.173Z 16:52:50.173 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@726aa968 16:52:50.173 [qtp1291485735-63] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$228/685407505@726aa968 16:52:50.173 [qtp1291485735-63] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@54d8c20d/SelectorProducer@4b65d9f4/IDLE/p=false/QueuedThreadPool[qtp1291485735]@4cfa8227{STARTED,8<=8<=200,i=5,q=0}[ReservedThreadExecutor@2d9dff65{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:52:50.173Z tryProduce false 16:52:50.173 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 0 16:52:50.173 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:52:50.173 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@287dc436 waiting with 0 keys 16:52:50.173 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@7100dea on ManagedSelector@44536de4{STARTING} id=2 keys=0 selected=0 updates=0 16:52:50.173 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Wakeup on submit ManagedSelector@44536de4{STARTING} id=2 keys=0 selected=0 updates=1 16:52:50.173 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@287dc436 woken with none selected 16:52:50.173 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@287dc436 woken up from select, 0/0/0 selected 16:52:50.174 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@287dc436 processing 0 keys, 1 updates 16:52:50.174 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:52:50.174 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@7100dea 16:52:50.174 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:52:50.174 [qtp1291485735-63] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@287dc436 waiting with 0 keys 16:52:50.174 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2280ms ManagedSelector@44536de4{STARTED} id=2 keys=0 selected=0 updates=0 16:52:50.174 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2280ms SelectorManager@ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:52:50.174 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {acceptor-0@15639440,POJO} 16:52:50.175 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue acceptor-0@15639440 16:52:50.175 [main] INFO o.e.jetty.server.AbstractConnector - Started ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:52:50.175 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2281ms ServerConnector@17d32e9b{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:52:50.175 [qtp1291485735-64] DEBUG o.e.j.util.thread.QueuedThreadPool - run acceptor-0@15639440 16:52:50.175 [main] INFO org.eclipse.jetty.server.Server - Started @2281ms 16:52:50.175 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2281ms Server@687e4c93{STARTED}[9.4.z-SNAPSHOT] 16:52:50.175 [main] INFO i.d.c.c.CassandraConnectorTask - Starting JMX reporter ... 16:52:50.226 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Finished reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325150.log 16:52:50.227 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'io.debezium.connector.cassandra.EOFEvent@79c79321' 16:52:50.227 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Successfully processed commit log CommitLog-6-1587055325150.log 16:52:50.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:50.759 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:52:50.759 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:50.824 [pool-3-thread-1] DEBUG i.d.c.cassandra.CommitLogUtil - Deleted commit log CommitLog-6-1587055325148.log in cdc directory 16:52:50.825 [pool-3-thread-2] DEBUG i.d.c.cassandra.CommitLogUtil - Deleted commit log CommitLog-6-1587055325150.log in cdc directory 16:52:50.984 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initialize connection to node kafka1:9092 (id: -1 rack: null) for sending metadata request 16:52:50.985 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating connection to node kafka1:9092 (id: -1 rack: null) using address kafka1/172.21.0.3 16:52:50.993 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 16:52:50.993 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 16:52:50.995 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 16:52:50.996 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.network.Selector - [Producer clientId=producer-1] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 16:52:51.131 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Completed connection to node -1. Fetching API versions. 16:52:51.131 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node -1. 16:52:51.213 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node -1. 16:52:51.214 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Using older server API v0 to send API_VERSIONS {} with correlation id 1 to node -1 16:52:51.217 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Recorded API versions for node -1: (Produce(0): 0 to 7 [usable: 7], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 8 [usable: 8], LeaderAndIsr(4): 0 to 2 [usable: 2], StopReplica(5): 0 to 1 [usable: 1], UpdateMetadata(6): 0 to 5 [usable: 5], ControlledShutdown(7): 0 to 2 [usable: 2], OffsetCommit(8): 0 to 7 [usable: 7], OffsetFetch(9): 0 to 5 [usable: 5], FindCoordinator(10): 0 to 2 [usable: 2], JoinGroup(11): 0 to 5 [usable: 5], Heartbeat(12): 0 to 3 [usable: 3], LeaveGroup(13): 0 to 2 [usable: 2], SyncGroup(14): 0 to 3 [usable: 3], DescribeGroups(15): 0 to 3 [usable: 3], ListGroups(16): 0 to 2 [usable: 2], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 2 [usable: 2], CreateTopics(19): 0 to 3 [usable: 3], DeleteTopics(20): 0 to 3 [usable: 3], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 1 [usable: 1], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 1 [usable: 1], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 1 [usable: 1], ElectLeaders(43): 0 [usable: 0], IncrementalAlterConfigs(44): 0 [usable: 0], AlterPartitionReassignments(45): UNSUPPORTED, ListPartitionReassignments(46): UNSUPPORTED, OffsetDelete(47): UNSUPPORTED) 16:52:51.218 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka1:9092 (id: -1 rack: null) 16:52:51.219 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Using older server API v8 to send METADATA {topics=[],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2 to node -1 16:52:51.227 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Cluster ID: iBAxSx52QtqPUKg4y6eePA 16:52:51.227 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updated cluster metadata updateVersion 2 to MetadataCache{clusterId='iBAxSx52QtqPUKg4y6eePA', nodes=[kafka1:9092 (id: 1 rack: null)], partitions=[], controller=kafka1:9092 (id: 1 rack: null)} 16:52:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:53.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:53.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:54.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:54.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:55.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:55.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:52:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:58.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:58.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:52:59.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:52:59.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:00.009 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:00.010 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:00.010 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:00.021 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:01.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:01.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:01.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:02.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:02.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:03.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:03.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:04.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:05.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:05.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:06.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:06.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:08.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:08.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:09.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:09.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:10.010 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:10.011 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:10.012 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:10.022 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:10.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:10.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:11.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:11.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:12.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:12.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:12.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:13.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:13.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:14.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:14.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:15.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:15.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:16.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:16.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:17.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:17.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:18.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:18.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:18.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:19.680 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:53:19.683 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:53:19.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:19.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:19.763 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:53:19.765 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:53:20.012 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:20.013 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:20.013 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:20.023 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:20.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:20.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:21.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:21.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:22.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:22.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:23.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:23.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:25.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:25.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:26.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:26.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:27.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:27.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:28.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:28.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:29.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:29.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:29.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:30.014 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:30.015 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:30.015 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:30.024 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:30.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:30.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:31.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:31.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:32.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:32.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:33.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:33.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:36.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:36.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:37.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:37.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:38.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:38.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:39.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:39.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:40.015 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:40.016 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:40.016 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:40.024 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:40.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:40.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:40.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:41.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:41.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:42.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:42.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:43.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:43.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:44.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:44.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:45.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:45.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:46.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:46.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:46.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:47.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:47.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:48.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:48.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:49.709 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:53:49.712 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:53:49.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:49.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:49.795 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:53:49.797 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:53:50.016 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:53:50.017 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:53:50.017 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:53:50.025 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:53:50.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:50.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:52.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:53.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:53.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:54.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:54.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:55.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:55.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:56.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:58.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:53:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:53:59.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:53:59.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:00.018 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:00.019 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:00.019 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:00.026 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:01.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:01.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:02.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:02.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:03.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:03.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:06.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:06.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:07.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:08.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:08.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:09.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:09.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:10.019 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:10.020 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:10.020 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:10.027 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:10.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:10.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:10.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:11.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:11.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:12.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:12.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:13.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:13.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:14.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:14.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:15.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:15.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:16.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:16.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:16.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:17.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:17.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:18.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:18.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:19.728 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:54:19.730 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:54:19.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:19.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:19.801 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:54:19.803 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:54:20.020 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:20.021 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:20.021 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:20.028 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:20.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:20.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:21.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:21.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:21.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:22.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:22.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:23.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:23.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:25.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:25.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:26.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:26.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:28.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:28.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:29.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:29.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:30.022 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:30.022 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:30.022 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:30.029 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:30.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:30.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:31.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:31.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:32.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:32.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:33.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:33.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:33.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:35.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:36.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:36.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:37.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:37.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:38.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:38.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:38.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:39.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:39.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:40.023 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:40.023 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:40.023 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:40.030 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:40.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:40.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:41.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:41.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:42.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:42.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:43.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:43.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:44.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:44.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:44.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:45.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:45.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:46.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:46.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:47.443 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Processing commit log CommitLog-6-1587055325151.log 16:54:47.444 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325151.log (CL version 6, messaging version 11, compression null) 16:54:47.513 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Finished reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325151.log 16:54:47.514 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'io.debezium.connector.cassandra.EOFEvent@6701de19' 16:54:47.514 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Successfully processed commit log CommitLog-6-1587055325151.log 16:54:47.514 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Processing commit log CommitLog-6-1587055325152.log 16:54:47.514 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325152.log (CL version 6, messaging version 11, compression null) 16:54:47.579 [pool-4-thread-2] DEBUG o.a.c.db.commitlog.CommitLogReader - Finished reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325152.log 16:54:47.579 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'io.debezium.connector.cassandra.EOFEvent@26233fcc' 16:54:47.579 [pool-4-thread-2] INFO i.d.c.cassandra.CommitLogProcessor - Successfully processed commit log CommitLog-6-1587055325152.log 16:54:47.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:47.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:47.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:47.787 [pool-3-thread-3] DEBUG i.d.c.cassandra.CommitLogUtil - Deleted commit log CommitLog-6-1587055325151.log in cdc directory 16:54:47.787 [pool-3-thread-4] DEBUG i.d.c.cassandra.CommitLogUtil - Deleted commit log CommitLog-6-1587055325152.log in cdc directory 16:54:48.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:48.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:49.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:49.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:49.752 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:54:49.754 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:54:49.812 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:54:49.814 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:54:50.023 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:54:50.024 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:54:50.024 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:54:50.030 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:54:50.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:50.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:52.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:52.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:53.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:53.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:53.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:54.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:54.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:55.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:55.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:56.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:56.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:54:59.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:54:59.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:54:59.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:00.025 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:00.026 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:00.026 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:00.031 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:00.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:01.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:01.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:02.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:02.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:03.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:03.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:06.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:06.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:07.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:08.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:08.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:09.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:09.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:10.026 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:10.027 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:10.027 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:10.032 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:10.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:10.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:10.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:11.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:11.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:12.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:12.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:13.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:13.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:14.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:14.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:15.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:15.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:16.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:16.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:16.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:17.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:17.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:18.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:18.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:19.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:19.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:19.783 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:55:19.785 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:55:19.842 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:55:19.845 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:55:20.027 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:20.028 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:20.028 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:20.032 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:20.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:20.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:21.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:21.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:22.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:22.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:22.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:23.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:23.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:24.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:25.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:25.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:26.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:26.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:27.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:28.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:28.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:29.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:29.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:30.029 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:30.029 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:30.029 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:30.033 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:30.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:30.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:31.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:31.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:32.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:32.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:32.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:33.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:33.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:34.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:35.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:36.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:36.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:37.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:37.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:38.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:38.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:38.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:39.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:39.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:40.030 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:40.031 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:40.031 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:40.033 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:40.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:40.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:41.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:41.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:42.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:42.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:43.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:43.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:43.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:44.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:44.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:45.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:45.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:46.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:46.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:47.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:47.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:48.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:48.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:49.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:49.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:49.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:49.791 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:55:49.794 [cluster1-nio-worker-0] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-1, inFlight=0, closed=false] heartbeat query succeeded 16:55:49.865 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] was inactive for 30 seconds, sending heartbeat 16:55:49.867 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Connection - Connection[cassandra-seed/172.21.0.5:9042-2, inFlight=0, closed=false] heartbeat query succeeded 16:55:50.032 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:55:50.033 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:55:50.033 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:55:50.034 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:55:50.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:50.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:51.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:52.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:53.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:53.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:54.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:54.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:55.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:55.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:55:55.754 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:56.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:57.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:58.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:55:59.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:55:59.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:00.034 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:56:00.034 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:56:00.034 [pool-4-thread-3] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:56:00.035 [pool-4-thread-5] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:56:00.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:00.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:01.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:01.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:56:01.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:02.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:02.753 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:03.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:03.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:04.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:05.752 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:06.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:06.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:56:07.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:56:07.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:56:07.751 [pool-4-thread-1] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit...