16:43:21.502 [main] INFO i.d.c.c.CassandraConnectorTask - Initializing Cassandra connector task context ... 16:43:21.513 [main] INFO o.a.c.config.YamlConfigurationLoader - Configuration location: file:////etc/cassandra/cassandra.yaml 16:43:21.514 [main] DEBUG o.a.c.config.YamlConfigurationLoader - Loading settings from file:////etc/cassandra/cassandra.yaml 16:43:21.734 [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:43:21.735 [main] DEBUG o.a.c.config.DatabaseDescriptor - Syncing log with a period of 10000 16:43:21.735 [main] INFO o.a.c.config.DatabaseDescriptor - DiskAccessMode 'auto' determined to be mmap, indexAccessMode is mmap 16:43:21.735 [main] INFO o.a.c.config.DatabaseDescriptor - Global memtable on-heap threshold is enabled at 274MB 16:43:21.735 [main] INFO o.a.c.config.DatabaseDescriptor - Global memtable off-heap threshold is enabled at 274MB 16:43:21.739 [main] INFO o.a.c.config.DatabaseDescriptor - cdc_enabled is true. Starting casssandra node with Change-Data-Capture enabled. 16:43:21.837 [main] WARN o.a.c.config.DatabaseDescriptor - Only 45.986GiB free across all data volumes. Consider adding more capacity to your cluster or removing obsolete snapshots 16:43:21.857 [main] INFO o.a.c.net.RateBasedBackPressure - Initialized back-pressure with high ratio: 0.9, factor: 5, flow: FAST, window size: 2000. 16:43:21.857 [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:43:21.946 [main] INFO o.a.cassandra.cql3.QueryProcessor - Initialized prepared statement caches with 10 MB (native) and 10 MB (Thrift) 16:43:22.143 [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:43:22.149 [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:43:22.151 [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:43:22.151 [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:43:22.152 [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:43:22.153 [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:43:22.153 [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:43:22.154 [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:43:22.156 [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:43:22.157 [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:43:22.210 [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:43:22.211 [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:43:22.211 [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:43:22.212 [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:43:22.213 [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:43:22.214 [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:43:22.214 [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:43:22.215 [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:43:22.216 [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:43:22.217 [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:43:22.217 [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:43:22.218 [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:43:22.218 [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:43:22.219 [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:43:22.220 [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:43:22.221 [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:43:22.221 [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:43:22.222 [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:43:22.223 [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:43:22.223 [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:43:22.224 [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:43:22.224 [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:43:22.225 [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:43:22.225 [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:43:22.312 [main] DEBUG org.apache.cassandra.db.Keyspace - New replication settings for keyspace system_schema - invalidating disk boundary caches 16:43:22.445 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.keyspaces 16:43:22.473 [SSTableBatchOpen:2] 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:43:22.486 [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:43:22.486 [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:43:22.615 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.keyspaces 16:43:22.620 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.620 [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:43:22.631 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.tables 16:43:22.634 [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:43:22.636 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.tables 16:43:22.636 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.636 [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:43:22.644 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.columns 16:43:22.649 [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:43:22.649 [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:43:22.651 [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:43:22.653 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.columns 16:43:22.653 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.653 [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:43:22.659 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.triggers 16:43:22.662 [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:43:22.663 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.triggers 16:43:22.663 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.663 [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:43:22.669 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.dropped_columns 16:43:22.672 [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:43:22.673 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.dropped_columns 16:43:22.673 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.674 [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:43:22.679 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.views 16:43:22.682 [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:43:22.684 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.views 16:43:22.684 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.684 [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:43:22.689 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.types 16:43:22.692 [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:43:22.693 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.types 16:43:22.694 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.694 [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:43:22.699 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.functions 16:43:22.702 [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:43:22.704 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.functions 16:43:22.704 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.704 [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:43:22.709 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.aggregates 16:43:22.711 [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:43:22.712 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.aggregates 16:43:22.712 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.712 [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:43:22.717 [main] INFO o.a.cassandra.db.ColumnFamilyStore - Initializing system_schema.indexes 16:43:22.719 [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:43:22.721 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Refreshing disk boundary cache for system_schema.indexes 16:43:22.721 [main] DEBUG o.a.cassandra.db.DiskBoundaryManager - Got local ranges [] (ringVersion = 0) 16:43:22.721 [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:43:22.721 [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:43:22.775 [main] INFO o.a.c.db.monitoring.ApproximateTime - Scheduling approximate time-check task with a precision of 10 milliseconds 16:43:22.890 [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:43:22.891 [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:43:22.891 [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:43:22.891 [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:43:22.892 [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:43:22.892 [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:43:22.893 [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:43:22.893 [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:43:22.894 [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:43:22.894 [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:43:22.895 [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:43:22.899 [main] INFO com.datastax.driver.core - DataStax Java driver 3.5.0 for Apache Cassandra 16:43:22.905 [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:43:22.916 [main] INFO c.d.driver.core.GuavaCompatibility - Detected Guava < 19 in the classpath, using legacy compatibility layer 16:43:22.916 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NEW_NODE_DELAY_SECONDS is undefined, using default value 1 16:43:22.916 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NOTIF_LOCK_TIMEOUT_SECONDS is undefined, using default value 60 16:43:22.925 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.USE_NATIVE_CLOCK is undefined, using default value true 16:43:23.063 [main] INFO c.datastax.driver.core.ClockFactory - Using native clock to generate timestamps. 16:43:23.066 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.NON_BLOCKING_EXECUTOR_SIZE is undefined, using default value 6 16:43:23.091 [main] DEBUG com.datastax.driver.core.Cluster - Starting new cluster with contact points [cassandra-seed/172.21.0.5:9042] 16:43:23.102 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework 16:43:23.113 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false 16:43:23.115 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available 16:43:23.115 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available 16:43:23.115 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available 16:43:23.115 [main] DEBUG i.n.util.internal.PlatformDependent0 - direct buffer constructor: available 16:43:23.116 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: available, true 16:43:23.116 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.DirectByteBuffer.(long, int): available 16:43:23.117 [main] DEBUG io.netty.util.internal.Cleaner0 - java.nio.ByteBuffer.cleaner(): available 16:43:23.117 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8 16:43:23.117 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available 16:43:23.117 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false 16:43:23.118 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable 16:43:23.118 [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:43:23.118 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 16:43:23.118 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model) 16:43:23.118 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false 16:43:23.118 [main] DEBUG i.n.util.internal.PlatformDependent - io.netty.maxDirectMemory: 1152385024 bytes 16:43:23.123 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FORCE_NIO is undefined, using default value false 16:43:23.125 [main] DEBUG i.n.u.internal.NativeLibraryLoader - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 16:43:23.125 [main] DEBUG i.n.u.internal.NativeLibraryLoader - -Dio.netty.native.workdir: /tmp (io.netty.tmpdir) 16:43:23.133 [main] DEBUG io.netty.util.NetUtil - Loopback interface: lo (lo, 127.0.0.1) 16:43:23.133 [main] DEBUG io.netty.util.NetUtil - /proc/sys/net/core/somaxconn: 128 16:43:23.135 [main] INFO com.datastax.driver.core.NettyUtil - Found Netty's native epoll transport in the classpath, using it 16:43:23.145 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 12 16:43:23.152 [main] DEBUG i.n.util.internal.PlatformDependent - org.jctools-core.MpscChunkedArrayQueue: available 16:43:23.167 [main] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetection.level: simple 16:43:23.167 [main] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetection.maxRecords: 4 16:43:23.167 [main] DEBUG i.n.util.ResourceLeakDetectorFactory - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@79767781 16:43:23.170 [main] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0x3e0c35d604d658e3 (took 0 ms) 16:43:23.174 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.EXTENDED_PEER_CHECK is undefined, using default value true 16:43:23.183 [main] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] preparing to open 1 new connections, total = 1 16:43:23.185 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.DISABLE_COALESCING is undefined, using default value false 16:43:23.186 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FLUSHER_SCHEDULE_PERIOD_NS is undefined, using default value 10000 16:43:23.186 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.FLUSHER_RUN_WITHOUT_WORK_TIMES is undefined, using default value 5 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 11 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 11 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192 16:43:23.202 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.useCacheForAllThreads: true 16:43:23.227 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled 16:43:23.227 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 65536 16:43:23.228 [main] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.maxThreadLocalCharBufferSize: 16384 16:43:23.245 [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:43:23.256 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 32768 16:43:23.257 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxSharedCapacityFactor: 2 16:43:23.257 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.linkCapacity: 16 16:43:23.257 [cluster1-nio-worker-0] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.ratio: 8 16:43:23.267 [cluster1-nio-worker-0] DEBUG io.netty.buffer.AbstractByteBuf - -Dio.netty.buffer.bytebuf.checkAccessible: true 16:43:23.267 [cluster1-nio-worker-0] DEBUG i.n.util.ResourceLeakDetectorFactory - Loaded default ResourceLeakDetector: io.netty.util.ResourceLeakDetector@6ec84bb1 16:43:23.276 [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:43:23.277 [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:43:23.278 [main] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing node list and token map 16:43:23.328 [main] DEBUG c.d.driver.core.ControlConnection - [Control connection] Refreshing schema 16:43:23.457 [main] DEBUG com.datastax.driver.core.Host.STATES - [Control connection] established to cassandra-seed/172.21.0.5:9042 16:43:23.457 [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:43:23.458 [main] INFO com.datastax.driver.core.Cluster - New Cassandra host cassandra-seed/172.21.0.5:9042 added 16:43:23.462 [main] DEBUG c.d.driver.core.SystemProperties - com.datastax.driver.CHECK_IO_DEADLOCKS is undefined, using default value true 16:43:23.465 [main] DEBUG com.datastax.driver.core.Host.STATES - [cassandra-seed/172.21.0.5:9042] preparing to open 1 new connections, total = 2 16:43:23.467 [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:43:23.480 [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:43:23.481 [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:43:23.482 [cluster1-nio-worker-2] DEBUG com.datastax.driver.core.Session - Added connection pool for cassandra-seed/172.21.0.5:9042 16:43:23.486 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:43:23.497 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:43:23.497 [main] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:43:23.500 [main] INFO i.d.c.c.CassandraConnectorTask - Starting processor group ... 16:43:23.582 [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:43:23.695 [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:43:23.698 [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:43:23.744 [main] INFO i.c.connect.avro.AvroDataConfig - AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 16:43:23.745 [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:43:23.745 [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:43:23.745 [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:43:23.745 [main] INFO i.c.connect.avro.AvroDataConfig - AvroDataConfig values: connect.meta.data = true enhanced.avro.schema.support = false schemas.cache.config = 1000 16:43:23.755 [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:43:23.768 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time 16:43:23.771 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records 16:43:23.774 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name errors 16:43:23.780 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name produce-throttle-time 16:43:23.786 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed: 16:43:23.787 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created: 16:43:23.787 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-authentication: 16:43:23.787 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-reauthentication: 16:43:23.788 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name successful-authentication-no-reauth: 16:43:23.788 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name failed-authentication: 16:43:23.788 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name failed-reauthentication: 16:43:23.788 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name reauthentication-latency: 16:43:23.789 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received: 16:43:23.789 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent: 16:43:23.789 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-received: 16:43:23.790 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name select-time: 16:43:23.790 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name io-time: 16:43:23.794 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-size 16:43:23.794 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name compression-rate 16:43:23.794 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name queue-time 16:43:23.794 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name request-time 16:43:23.795 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name records-per-request 16:43:23.795 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-retries 16:43:23.795 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name record-size 16:43:23.797 [main] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name batch-split-rate 16:43:23.798 [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:43:23.799 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka version: 2.4.0 16:43:23.799 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka commitId: 77a89fcf8d7fa018 16:43:23.799 [main] INFO o.a.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1587055403798 16:43:23.800 [main] DEBUG o.a.k.clients.producer.KafkaProducer - [Producer clientId=producer-1] Kafka producer started 16:43:23.803 [main] INFO i.d.c.c.CassandraConnectorTask - Starting processor group Cassandra Connector Task 16:43:23.804 [pool-4-thread-1] INFO i.d.c.cassandra.AbstractProcessor - Started Commit Log Post-Processor 16:43:23.804 [pool-4-thread-2] INFO i.d.c.cassandra.AbstractProcessor - Started Change Event Queue Processor 16:43:23.805 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:23.806 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:23.810 [pool-4-thread-3] INFO i.d.c.cassandra.AbstractProcessor - Started Snapshot Processor 16:43:23.810 [pool-4-thread-4] INFO i.d.c.cassandra.AbstractProcessor - Started Schema Processor 16:43:23.810 [main] INFO i.d.c.c.CassandraConnectorTask - Starting HTTP server ... 16:43:23.810 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:43:23.811 [main] INFO i.d.c.c.CassandraConnectorTask - HTTP port is 8000 16:43:23.812 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:43:23.812 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:43:23.814 [pool-4-thread-5] INFO i.d.c.cassandra.AbstractProcessor - Started Commit Log Processor 16:43:23.814 [pool-4-thread-5] INFO i.d.c.cassandra.CommitLogProcessor - Reading existing commit logs in /var/lib/cassandra/cdc_raw 16:43:23.816 [pool-4-thread-3] INFO i.d.c.cassandra.SnapshotProcessor - Found 1 tables to snapshot: [keyspace1.standard1] 16:43:23.816 [pool-4-thread-3] INFO i.d.c.cassandra.SnapshotProcessor - Snapshotting table keyspace1.standard1 16:43:23.820 [main] DEBUG org.eclipse.jetty.util.log - Logging to Logger[org.eclipse.jetty.util.log] via org.eclipse.jetty.util.log.Slf4jLog 16:43:23.821 [main] INFO org.eclipse.jetty.util.log - Logging initialized @2610ms to org.eclipse.jetty.util.log.Slf4jLog 16:43:23.827 [pool-4-thread-3] INFO i.d.c.cassandra.SnapshotProcessor - Executing snapshot query 'SELECT UNIXTIMESTAMPOF(NOW()) AS execution_time,"key","C0",ttl("C0") AS C0_ttl,writetime("C0") AS C0_writetime,"C1",ttl("C1") AS C1_ttl,writetime("C1") AS C1_writetime,"C2",ttl("C2") AS C2_ttl,writetime("C2") AS C2_writetime,"C3",ttl("C3") AS C3_ttl,writetime("C3") AS C3_writetime,"C4",ttl("C4") AS C4_ttl,writetime("C4") AS C4_writetime FROM keyspace1.standard1;' with consistency level ONE 16:43:23.839 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@181e72d3{STOPPED}[9.4.z-SNAPSHOT] added {QueuedThreadPool[qtp2015521846]@78226c36{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$205/1291485735@684b31de],AUTO} 16:43:23.858 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - HttpConnectionFactory@3f725306[HTTP/1.1] added {HttpConfiguration@3c69362a{32768/8192,8192/8192,https://:0,[]},POJO} 16:43:23.860 [pool-4-thread-3] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'Record{source={cluster=Test Cluster, keyspace=keyspace1, file=, connector=cassandra, pos=-1, ts_micro=1587055397194000, version=1.1.0.Final, snapshot=true, table=standard1}, after={key={name=key, value=java.nio.HeapByteBuffer[pos=0 lim=10 cap=10], deletionTs=null, type=PARTITION}, C0={name=C0, value=java.nio.HeapByteBuffer[pos=0 lim=34 cap=34], deletionTs=null, type=REGULAR}, C1={name=C1, value=java.nio.HeapByteBuffer[pos=0 lim=34 cap=34], deletionTs=null, type=REGULAR}, C2={name=C2, value=java.nio.HeapByteBuffer[pos=0 lim=34 cap=34], deletionTs=null, type=REGULAR}, C3={name=C3, value=java.nio.HeapByteBuffer[pos=0 lim=34 cap=34], deletionTs=null, type=REGULAR}, C4={name=C4, value=java.nio.HeapByteBuffer[pos=0 lim=34 cap=34], deletionTs=null, type=REGULAR}}, keySchema=Schema{io.debezium.connector.cassandra.null.keyspace1.standard1.Key:STRUCT}, valueSchema=Schema{io.debezium.connector.cassandra.null.keyspace1.standard1.Value:STRUCT}, op=i, ts=1587055403860}' 16:43:23.860 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{null,[]}{0.0.0.0:0} added {Server@181e72d3{STOPPED}[9.4.z-SNAPSHOT],UNMANAGED} 16:43:23.860 [pool-4-thread-3] INFO i.d.c.cassandra.SnapshotProcessor - Snapshot completely queued in 0 seconds for tables: [keyspace1.standard1] 16:43:23.861 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{null,[]}{0.0.0.0:0} added {QueuedThreadPool[qtp2015521846]@78226c36{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$205/1291485735@684b31de],AUTO} 16:43:23.861 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{null,[]}{0.0.0.0:0} added {ScheduledExecutorScheduler@7c251f90{STOPPED},AUTO} 16:43:23.861 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{null,[]}{0.0.0.0:0} added {org.eclipse.jetty.io.ArrayByteBufferPool@2e6f610d,POJO} 16:43:23.861 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{null,[http/1.1]}{0.0.0.0:0} added {HttpConnectionFactory@3f725306[HTTP/1.1],AUTO} 16:43:23.861 [main] DEBUG o.e.jetty.server.AbstractConnector - ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:0} added HttpConnectionFactory@3f725306[HTTP/1.1] 16:43:23.864 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:0} added {SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:0},MANAGED} 16:43:23.864 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@181e72d3{STOPPED}[9.4.z-SNAPSHOT] added {ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000},AUTO} 16:43:23.882 [main] DEBUG o.e.j.util.DecoratedObjectFactory - Adding Decorator: org.eclipse.jetty.util.DeprecationWarning@761956ac 16:43:23.888 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - o.e.j.s.ServletContextHandler@44e93c1f{/,null,UNAVAILABLE} added {org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1,MANAGED} 16:43:23.892 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 added {ServletHandler@711d1a52{STOPPED},MANAGED} 16:43:23.894 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@181e72d3{STOPPED}[9.4.z-SNAPSHOT] added {o.e.j.s.ServletContextHandler@44e93c1f{/,null,UNAVAILABLE},MANAGED} 16:43:23.901 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true,AUTO} 16:43:23.902 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {[/ping]=>com.codahale.metrics.servlets.PingServlet-4b6d92e,POJO} 16:43:23.902 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true,AUTO} 16:43:23.902 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {[/buildinfo]=>io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f,POJO} 16:43:23.904 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true,AUTO} 16:43:23.904 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {[/metrics]=>com.codahale.metrics.servlets.MetricsServlet-f951a7f,POJO} 16:43:23.907 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true,AUTO} 16:43:23.907 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STOPPED} added {[/health]=>com.codahale.metrics.servlets.HealthCheckServlet-292158f8,POJO} 16:43:23.908 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting Server@181e72d3{STOPPED}[9.4.z-SNAPSHOT] 16:43:23.909 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@181e72d3{STARTING}[9.4.z-SNAPSHOT] added {ErrorHandler@6f49d153{STOPPED},AUTO} 16:43:23.911 [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:43:23.931 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting Server@181e72d3{STARTING}[9.4.z-SNAPSHOT] 16:43:23.931 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting QueuedThreadPool[qtp2015521846]@78226c36{STOPPED,8<=0<=200,i=0,q=0}[org.eclipse.jetty.util.thread.TryExecutor$$Lambda$205/1291485735@684b31de] 16:43:23.932 [main] DEBUG o.e.j.u.t.ReservedThreadExecutor - ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0} 16:43:23.932 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - QueuedThreadPool[qtp2015521846]@78226c36{STARTING,8<=0<=200,i=0,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}] added {ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0},AUTO} 16:43:23.932 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0} 16:43:23.935 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2725ms ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0} 16:43:23.940 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2729ms QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}] 16:43:23.940 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting o.e.j.s.ServletContextHandler@44e93c1f{/,null,UNAVAILABLE} 16:43:23.944 [main] DEBUG o.e.jetty.http.PreEncodedHttpField - HttpField encoders loaded: [org.eclipse.jetty.http.Http1FieldPreEncoder@7add323c] 16:43:23.952 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting o.e.j.s.ServletContextHandler@44e93c1f{/,null,STARTING} 16:43:23.952 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 16:43:23.955 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 added {org.eclipse.jetty.server.session.DefaultSessionCache@e5cbff2[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false],AUTO} 16:43:23.957 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.DefaultSessionCache@e5cbff2[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] added {org.eclipse.jetty.server.session.NullSessionDataStore@262816a8[passivating=false,graceSec=3600],AUTO} 16:43:23.958 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting DefaultSessionIdManager@6920614{STOPPED}[worker=null] 16:43:23.958 [main] INFO org.eclipse.jetty.server.session - DefaultSessionIdManager workerName=node0 16:43:23.958 [main] INFO org.eclipse.jetty.server.session - No SessionScavenger set, using defaults 16:43:23.958 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - DefaultSessionIdManager@6920614{STARTING}[worker=node0] added {HouseKeeper@558756be{STOPPED}[interval=600000, ownscheduler=false],MANAGED} 16:43:23.958 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting HouseKeeper@558756be{STOPPED}[interval=600000, ownscheduler=false] 16:43:23.959 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@433348bc{STOPPED} 16:43:23.959 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2748ms ScheduledExecutorScheduler@433348bc{STARTED} 16:43:23.959 [main] DEBUG org.eclipse.jetty.server.session - Using own scheduler for scavenging 16:43:23.959 [main] INFO org.eclipse.jetty.server.session - node0 Scavenging every 600000ms 16:43:23.960 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2749ms HouseKeeper@558756be{STARTED}[interval=600000, ownscheduler=true] 16:43:23.960 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2749ms DefaultSessionIdManager@6920614{STARTED}[worker=node0] 16:43:23.960 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - Server@181e72d3{STARTING}[9.4.z-SNAPSHOT] added {DefaultSessionIdManager@6920614{STARTED}[worker=node0],MANAGED} 16:43:23.960 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 added {DefaultSessionIdManager@6920614{STARTED}[worker=node0],UNMANAGED} 16:43:23.961 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@6403e24c{STOPPED} 16:43:23.961 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2750ms ScheduledExecutorScheduler@6403e24c{STARTED} 16:43:23.961 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 16:43:23.961 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ServletHandler@711d1a52{STOPPED} 16:43:23.962 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/health[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.HealthCheckServlet-292158f8[EMBEDDED:null] 16:43:23.964 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/health",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true] to PathMappings[size=1] 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/buildinfo[EMBEDDED:null] mapped to servlet=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f[EMBEDDED:null] 16:43:23.964 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/buildinfo",pathDepth=1,group=EXACT],resource=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true] to PathMappings[size=2] 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/ping[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.PingServlet-4b6d92e[EMBEDDED:null] 16:43:23.964 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/ping",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true] to PathMappings[size=3] 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/metrics[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.MetricsServlet-f951a7f[EMBEDDED:null] 16:43:23.964 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/metrics",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true] to PathMappings[size=4] 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - filterNameMap={} 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - pathFilters=null 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletFilterMap=null 16:43:23.964 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletPathMap=PathMappings[size=4] 16:43:23.965 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletNameMap={com.codahale.metrics.servlets.HealthCheckServlet-292158f8=com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.PingServlet-4b6d92e=com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.MetricsServlet-f951a7f=com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true, io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true} 16:43:23.965 [main] DEBUG o.e.jetty.servlet.ServletHandler - Adding Default404Servlet to ServletHandler@711d1a52{STARTING} 16:43:23.965 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STARTING} added {org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b@957828cc==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false,AUTO} 16:43:23.965 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServletHandler@711d1a52{STARTING} added {[/]=>org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b,POJO} 16:43:23.965 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/health[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.HealthCheckServlet-292158f8[EMBEDDED:null] 16:43:23.965 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/health",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true] to PathMappings[size=1] 16:43:23.965 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/buildinfo[EMBEDDED:null] mapped to servlet=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f[EMBEDDED:null] 16:43:23.966 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/buildinfo",pathDepth=1,group=EXACT],resource=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true] to PathMappings[size=2] 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/ping[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.PingServlet-4b6d92e[EMBEDDED:null] 16:43:23.966 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/ping",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true] to PathMappings[size=3] 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/metrics[EMBEDDED:null] mapped to servlet=com.codahale.metrics.servlets.MetricsServlet-f951a7f[EMBEDDED:null] 16:43:23.966 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/metrics",pathDepth=1,group=EXACT],resource=com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true] to PathMappings[size=4] 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - Path=/[EMBEDDED:null] mapped to servlet=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b[EMBEDDED:null] 16:43:23.966 [main] DEBUG o.e.jetty.http.pathmap.PathMappings - Added MappedResource[pathSpec=ServletPathSpec["/",pathDepth=-1,group=DEFAULT],resource=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b@957828cc==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false] to PathMappings[size=5] 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - filterNameMap={} 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - pathFilters=null 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletFilterMap=null 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletPathMap=PathMappings[size=5] 16:43:23.966 [main] DEBUG o.e.jetty.servlet.ServletHandler - servletNameMap={com.codahale.metrics.servlets.HealthCheckServlet-292158f8=com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true, com.codahale.metrics.servlets.PingServlet-4b6d92e=com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true, org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b=org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b@957828cc==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false, com.codahale.metrics.servlets.MetricsServlet-f951a7f=com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true, io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f=io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true} 16:43:23.966 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting ServletHandler@711d1a52{STARTING} 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2756ms ServletHandler@711d1a52{STARTED} 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.DefaultSessionCache@e5cbff2[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.server.session.NullSessionDataStore@262816a8[passivating=false,graceSec=3600] 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2756ms org.eclipse.jetty.server.session.NullSessionDataStore@262816a8[passivating=false,graceSec=3600] 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2756ms org.eclipse.jetty.server.session.DefaultSessionCache@e5cbff2[evict=-1,removeUnloadable=false,saveOnCreate=false,saveOnInactiveEvict=false] 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2756ms org.eclipse.jetty.server.session.SessionHandler1110913929==dftMaxIdleSec=-1 16:43:23.967 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true 16:43:23.968 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2757ms com.codahale.metrics.servlets.HealthCheckServlet-292158f8@10b178c0==com.codahale.metrics.servlets.HealthCheckServlet,jsp=null,order=-1,inst=true 16:43:23.969 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.HealthCheckServlet@a66e580 for com.codahale.metrics.servlets.HealthCheckServlet-292158f8 16:43:23.973 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true 16:43:23.973 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2762ms com.codahale.metrics.servlets.MetricsServlet-f951a7f@92df1125==com.codahale.metrics.servlets.MetricsServlet,jsp=null,order=-1,inst=true 16:43:23.973 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.MetricsServlet@46963479 for com.codahale.metrics.servlets.MetricsServlet-f951a7f 16:43:23.976 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true 16:43:23.976 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2766ms com.codahale.metrics.servlets.PingServlet-4b6d92e@f8b5ba47==com.codahale.metrics.servlets.PingServlet,jsp=null,order=-1,inst=true 16:43:23.976 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init com.codahale.metrics.servlets.PingServlet@77774571 for com.codahale.metrics.servlets.PingServlet-4b6d92e 16:43:23.976 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true 16:43:23.976 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2766ms io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f@7daebef2==io.debezium.connector.cassandra.network.BuildInfoServlet,jsp=null,order=-1,inst=true 16:43:23.976 [main] DEBUG o.e.jetty.servlet.ServletHolder - Servlet.init io.debezium.connector.cassandra.network.BuildInfoServlet@277b8fa4 for io.debezium.connector.cassandra.network.BuildInfoServlet-13d9261f 16:43:23.976 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b@957828cc==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false 16:43:23.977 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2766ms org.eclipse.jetty.servlet.ServletHandler$Default404Servlet-2849434b@957828cc==org.eclipse.jetty.servlet.ServletHandler$Default404Servlet,jsp=null,order=-1,inst=false 16:43:23.977 [main] INFO o.e.j.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@44e93c1f{/,null,AVAILABLE} 16:43:23.977 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2767ms o.e.j.s.ServletContextHandler@44e93c1f{/,null,AVAILABLE} 16:43:23.977 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ErrorHandler@6f49d153{STOPPED} 16:43:23.977 [main] DEBUG o.e.j.server.handler.AbstractHandler - starting ErrorHandler@6f49d153{STARTING} 16:43:23.977 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2767ms ErrorHandler@6f49d153{STARTED} 16:43:23.978 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:43:23.982 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {sun.nio.ch.ServerSocketChannelImpl[/0.0.0.0:8000],POJO} 16:43:23.983 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ScheduledExecutorScheduler@7c251f90{STOPPED} 16:43:23.983 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2772ms ScheduledExecutorScheduler@7c251f90{STARTED} 16:43:23.983 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting HttpConnectionFactory@3f725306[HTTP/1.1] 16:43:23.983 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2772ms HttpConnectionFactory@3f725306[HTTP/1.1] 16:43:23.983 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:43:23.991 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.989Z added {SelectorProducer@467b684d,POJO} 16:43:23.992 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.991Z added {QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}],UNMANAGED} 16:43:23.992 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.992Z created 16:43:23.992 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@5af8bb51{STOPPED} id=0 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.992Z,MANAGED} 16:43:23.992 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@5af8bb51{STOPPED} id=0 keys=-1 selected=-1 updates=0,AUTO} 16:43:23.993 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.992Z added {SelectorProducer@2e66bc32,POJO} 16:43:23.993 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.993Z added {QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}],UNMANAGED} 16:43:23.993 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.993Z created 16:43:23.994 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@54d8c20d{STOPPED} id=1 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.993Z,MANAGED} 16:43:23.995 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@54d8c20d{STOPPED} id=1 keys=-1 selected=-1 updates=0,AUTO} 16:43:23.995 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.995Z added {SelectorProducer@44536de4,POJO} 16:43:23.996 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.995Z added {QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}],UNMANAGED} 16:43:23.996 [main] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.996Z created 16:43:23.996 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ManagedSelector@5fcfde70{STOPPED} id=2 keys=-1 selected=-1 updates=0 added {EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.996Z,MANAGED} 16:43:23.996 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {ManagedSelector@5fcfde70{STOPPED} id=2 keys=-1 selected=-1 updates=0,AUTO} 16:43:23.996 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@5af8bb51{STOPPED} id=0 keys=-1 selected=-1 updates=0 16:43:23.997 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.996Z 16:43:23.997 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2786ms EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=8,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.997Z 16:43:23.998 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@5624657a 16:43:23.998 [qtp2015521846-61] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@5624657a 16:43:23.998 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@36681447 on ManagedSelector@5af8bb51{STARTING} id=0 keys=0 selected=0 updates=0 16:43:23.998 [qtp2015521846-61] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@a451491/SelectorProducer@467b684d/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:23.998Z tryProduce false 16:43:23.999 [qtp2015521846-61] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:43:24.000 [qtp2015521846-61] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@36681447 16:43:24.000 [qtp2015521846-61] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:43:24.000 [qtp2015521846-61] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@36ef14e8 waiting with 0 keys 16:43:24.000 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2789ms ManagedSelector@5af8bb51{STARTED} id=0 keys=0 selected=0 updates=0 16:43:24.000 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@54d8c20d{STOPPED} id=1 keys=-1 selected=-1 updates=0 16:43:24.000 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24Z 16:43:24.000 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2790ms EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=7,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24Z 16:43:24.001 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@4d21c56e 16:43:24.001 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@726aa968 on ManagedSelector@54d8c20d{STARTING} id=1 keys=0 selected=0 updates=0 16:43:24.001 [qtp2015521846-62] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@4d21c56e 16:43:24.001 [qtp2015521846-62] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@799ed4e8/SelectorProducer@2e66bc32/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24.001Z tryProduce false 16:43:24.001 [qtp2015521846-62] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:43:24.001 [qtp2015521846-62] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@726aa968 16:43:24.001 [qtp2015521846-62] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:43:24.001 [qtp2015521846-62] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@528b8dee waiting with 0 keys 16:43:24.001 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2791ms ManagedSelector@54d8c20d{STARTED} id=1 keys=0 selected=0 updates=0 16:43:24.001 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting ManagedSelector@5fcfde70{STOPPED} id=2 keys=-1 selected=-1 updates=0 16:43:24.002 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - starting EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24.002Z 16:43:24.002 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2791ms EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=6,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24.002Z 16:43:24.002 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@7100dea 16:43:24.002 [qtp2015521846-65] DEBUG o.e.j.util.thread.QueuedThreadPool - run org.eclipse.jetty.io.ManagedSelector$$Lambda$234/2008619427@7100dea 16:43:24.002 [main] DEBUG org.eclipse.jetty.io.ManagedSelector - Queued change org.eclipse.jetty.io.ManagedSelector$Start@712cfb63 on ManagedSelector@5fcfde70{STARTING} id=2 keys=0 selected=0 updates=0 16:43:24.002 [qtp2015521846-65] DEBUG o.e.j.u.t.strategy.EatWhatYouKill - EatWhatYouKill@4b65d9f4/SelectorProducer@44536de4/IDLE/p=false/QueuedThreadPool[qtp2015521846]@78226c36{STARTED,8<=8<=200,i=5,q=0}[ReservedThreadExecutor@5ef6fd7f{s=0/6,p=0}][pc=0,pic=0,pec=0,epc=0]@2020-04-16T16:43:24.002Z tryProduce false 16:43:24.002 [qtp2015521846-65] DEBUG org.eclipse.jetty.io.ManagedSelector - updateable 1 16:43:24.002 [qtp2015521846-65] DEBUG org.eclipse.jetty.io.ManagedSelector - update org.eclipse.jetty.io.ManagedSelector$Start@712cfb63 16:43:24.002 [qtp2015521846-65] DEBUG org.eclipse.jetty.io.ManagedSelector - updates 0 16:43:24.002 [qtp2015521846-65] DEBUG org.eclipse.jetty.io.ManagedSelector - Selector sun.nio.ch.EPollSelectorImpl@7e3b7867 waiting with 0 keys 16:43:24.003 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2792ms ManagedSelector@5fcfde70{STARTED} id=2 keys=0 selected=0 updates=0 16:43:24.003 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2792ms SelectorManager@ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:43:24.003 [main] DEBUG o.e.j.u.component.ContainerLifeCycle - ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} added {acceptor-0@121bb45b,POJO} 16:43:24.003 [main] DEBUG o.e.j.util.thread.QueuedThreadPool - queue acceptor-0@121bb45b 16:43:24.004 [main] INFO o.e.jetty.server.AbstractConnector - Started ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:43:24.004 [qtp2015521846-63] DEBUG o.e.j.util.thread.QueuedThreadPool - run acceptor-0@121bb45b 16:43:24.004 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2793ms ServerConnector@66f0548d{HTTP/1.1,[http/1.1]}{0.0.0.0:8000} 16:43:24.004 [main] INFO org.eclipse.jetty.server.Server - Started @2793ms 16:43:24.004 [main] DEBUG o.e.j.u.component.AbstractLifeCycle - STARTED @2793ms Server@181e72d3{STARTED}[9.4.z-SNAPSHOT] 16:43:24.004 [main] INFO i.d.c.c.CassandraConnectorTask - Starting JMX reporter ... 16:43:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:24.555 [pool-4-thread-2] DEBUG i.c.k.s.client.rest.RestService - Sending POST with input {"schema":"{\"type\":\"record\",\"name\":\"Key\",\"namespace\":\"io.debezium.connector.cassandra.null.keyspace1.standard1\",\"fields\":[{\"name\":\"key\",\"type\":[\"null\",\"bytes\"],\"default\":null}],\"connect.name\":\"io.debezium.connector.cassandra.null.keyspace1.standard1.Key\"}"} to http://schemaregistry:8081/subjects/null.keyspace1.standard1-key/versions 16:43:24.775 [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:43:24.776 [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:43:24.782 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-sent 16:43:24.783 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.bytes-received 16:43:24.783 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node--1.latency 16:43:24.783 [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:43:25.036 [pool-4-thread-2] DEBUG i.c.k.s.client.rest.RestService - Sending POST with input {"schema":"{\"type\":\"record\",\"name\":\"Value\",\"namespace\":\"io.debezium.connector.cassandra.null.keyspace1.standard1\",\"fields\":[{\"name\":\"ts_ms\",\"type\":\"long\"},{\"name\":\"op\",\"type\":\"string\"},{\"name\":\"source\",\"type\":{\"type\":\"record\",\"name\":\"source\",\"namespace\":\"\",\"fields\":[{\"name\":\"version\",\"type\":\"string\"},{\"name\":\"connector\",\"type\":\"string\"},{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"ts_ms\",\"type\":\"long\"},{\"name\":\"snapshot\",\"type\":[{\"type\":\"string\",\"connect.version\":1,\"connect.parameters\":{\"allowed\":\"true,last,false\"},\"connect.default\":\"false\",\"connect.name\":\"io.debezium.data.Enum\"},\"null\"],\"default\":\"false\"},{\"name\":\"db\",\"type\":\"string\"},{\"name\":\"cluster\",\"type\":\"string\"},{\"name\":\"file\",\"type\":\"string\"},{\"name\":\"pos\",\"type\":\"int\"},{\"name\":\"keyspace\",\"type\":\"string\"},{\"name\":\"table\",\"type\":\"string\"}],\"connect.name\":\"source\"}},{\"name\":\"after\",\"type\":{\"type\":\"record\",\"name\":\"after\",\"namespace\":\"\",\"fields\":[{\"name\":\"key\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"key\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"key\"}],\"default\":null},{\"name\":\"C0\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"C0\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"C0\"}],\"default\":null},{\"name\":\"C1\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"C1\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"C1\"}],\"default\":null},{\"name\":\"C2\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"C2\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"C2\"}],\"default\":null},{\"name\":\"C3\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"C3\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"C3\"}],\"default\":null},{\"name\":\"C4\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"C4\",\"fields\":[{\"name\":\"value\",\"type\":[\"null\",\"bytes\"],\"default\":null},{\"name\":\"deletion_ts\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"set\",\"type\":\"boolean\"}],\"connect.name\":\"C4\"}],\"default\":null}],\"connect.name\":\"after\"}}],\"connect.name\":\"io.debezium.connector.cassandra.null.keyspace1.standard1.Value\"}"} to http://schemaregistry:8081/subjects/null.keyspace1.standard1-value/versions 16:43:25.046 [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:43:25.046 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node -1. 16:43:25.152 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node -1. 16:43:25.152 [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:43:25.155 [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:43:25.156 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='null.keyspace1.standard1')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka1:9092 (id: -1 rack: null) 16:43:25.157 [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=[{name=null.keyspace1.standard1}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2 to node -1 16:43:25.166 [kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Cluster ID: iBAxSx52QtqPUKg4y6eePA 16:43:25.167 [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=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = null.keyspace1.standard1, partition = 0, leader = 1, replicas = [1], isr = [1], offlineReplicas = []), epoch=-1}], controller=kafka1:9092 (id: 1 rack: null)} 16:43:25.177 [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:43:25.177 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-1.bytes-sent 16:43:25.178 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-1.bytes-received 16:43:25.179 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name node-1.latency 16:43:25.180 [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:43:25.180 [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:43:25.180 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node 1. 16:43:25.182 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Initiating API versions fetch from node 1. 16:43:25.182 [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 4 to node 1 16:43:25.184 [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:43:25.187 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.null.keyspace1.standard1.records-per-batch 16:43:25.188 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.null.keyspace1.standard1.bytes 16:43:25.188 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.null.keyspace1.standard1.compression-rate 16:43:25.188 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.null.keyspace1.standard1.record-retries 16:43:25.188 [kafka-producer-network-thread | producer-1] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name topic.null.keyspace1.standard1.record-errors 16:43:25.190 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Using older server API v7 to send PRODUCE {acks=1,timeout=30000,partitionSizes=[null.keyspace1.standard1-0=399]} with correlation id 5 to node 1 16:43:25.196 [pool-4-thread-2] INFO i.d.c.cassandra.KafkaRecordEmitter - Mark snapshot offset for table 'keyspace1.standard1' 16:43:25.200 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:25.200 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:25.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:25.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:31.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:31.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:33.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:33.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:33.813 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:43:33.813 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:43:33.813 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:43:33.861 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:43:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:37.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:39.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:39.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:41.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:43.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:43.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:43.814 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:43:43.814 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:43:43.814 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:43:43.861 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:43:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:45.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:45.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:46.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:47.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:47.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:47.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:49.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:49.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:51.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:53.377 [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:43:53.400 [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:43:53.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:53.814 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:43:53.815 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:43:53.815 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:43:53.858 [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:43:53.859 [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:43:53.862 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:43:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:57.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:57.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:58.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:58.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:43:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:43:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:43:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:00.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:00.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:02.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:03.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:03.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:03.815 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:03.816 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:03.816 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:03.862 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:05.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:06.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:06.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:09.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:09.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:11.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:12.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:12.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:13.816 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:13.816 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:13.816 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:13.863 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:14.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:14.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:15.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:15.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:17.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:17.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:19.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:20.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:20.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:22.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:23.401 [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:44:23.403 [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:44:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:23.817 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:23.817 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:23.817 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:23.863 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:23.887 [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:44:23.890 [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:44:24.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:24.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:27.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:27.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:27.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:28.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:28.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:29.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:30.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:31.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:31.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:33.818 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:33.818 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:33.819 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:33.864 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:35.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:35.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:37.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:37.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:38.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:38.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:40.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:42.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:42.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:43.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:43.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:43.819 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:43.820 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:43.820 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:43.864 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:44.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:44.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:45.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:45.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:45.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:46.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:46.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:47.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:49.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:50.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:50.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:53.430 [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:44:53.433 [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:44:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:53.821 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:44:53.821 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:44:53.821 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:44:53.866 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:44:53.897 [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:44:53.899 [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:44:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:54.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:56.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:56.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:44:56.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:58.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:58.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:44:59.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:44:59.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:00.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:00.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:02.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:02.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:03.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:03.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:03.822 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:03.823 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:03.823 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:03.867 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:05.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:05.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:08.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:08.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:11.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:12.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:12.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:13.824 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:13.824 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:13.824 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:13.868 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:14.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:14.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:14.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:15.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:15.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:17.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:18.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:19.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:19.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:20.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:20.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:20.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:21.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:23.447 [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:45:23.450 [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:45:23.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:23.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:23.825 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:23.826 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:23.826 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:23.868 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:23.900 [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:45:23.902 [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:45:24.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:24.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:25.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:25.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:25.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:26.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:26.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:27.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:27.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:30.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:31.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:32.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:32.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:33.827 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:33.827 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:33.827 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:33.869 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:36.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:37.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:37.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:40.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:40.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:41.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:43.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:43.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:43.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:43.828 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:43.829 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:43.829 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:43.870 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:44.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:44.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:46.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:46.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:50.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:51.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:51.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:52.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:52.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:53.454 [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:45:53.456 [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:45:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:53.830 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:45:53.831 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:45:53.831 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:45:53.871 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:45:53.932 [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:45:53.935 [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:45:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:45:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:56.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:56.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:57.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:57.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:58.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:58.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:45:59.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:45:59.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:03.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:03.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:03.832 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:03.833 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:03.833 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:03.873 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:04.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:04.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:07.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:08.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:10.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:10.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:11.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:11.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:11.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:12.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:12.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:13.835 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:13.835 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:13.835 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:13.874 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:14.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:15.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:15.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:20.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:20.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:23.458 [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:46:23.460 [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:46:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:23.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:23.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:23.836 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:23.837 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:23.837 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:23.874 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:23.960 [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:46:23.963 [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:46:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:30.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:30.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:32.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:33.838 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:33.839 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:33.839 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:33.877 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:35.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:35.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:35.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:38.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:38.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:41.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:41.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:41.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:42.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:43.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:43.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:43.840 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:43.841 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:43.841 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:43.879 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:47.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:49.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:52.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:52.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:52.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:53.479 [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:46:53.481 [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:46:53.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:53.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:53.841 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:46:53.842 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:46:53.842 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:46:53.880 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:46:53.970 [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:46:53.973 [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:46:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:54.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:55.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:55.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:58.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:58.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:46:58.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:46:59.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:46:59.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:00.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:00.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:01.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:01.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:02.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:02.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:03.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:03.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:03.843 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:03.844 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:03.844 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:03.881 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:04.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:04.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:04.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:05.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:05.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:06.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:06.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:08.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:09.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:13.845 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:13.846 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:13.846 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:13.881 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:15.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:15.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:17.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:17.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:18.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:18.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:20.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:20.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:21.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:21.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:22.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:23.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:23.487 [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:47:23.489 [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:47:23.846 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:23.847 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:23.847 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:23.882 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:23.999 [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:47:24.000 [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:47:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:26.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:26.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:28.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:28.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:29.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:30.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:30.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:31.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:32.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:32.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:32.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:33.848 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:33.848 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:33.848 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:33.883 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:34.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:35.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:38.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:38.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:38.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:39.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:40.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:40.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:41.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:41.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:43.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:43.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:43.849 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:43.850 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:43.850 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:43.884 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:48.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:49.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:49.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:50.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:51.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:52.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:53.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:53.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:53.504 [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:47:53.505 [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:47:53.850 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:47:53.851 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:47:53.851 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:47:53.885 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:47:54.025 [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:47:54.026 [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:47:54.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:54.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:55.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:47:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:57.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:57.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:58.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:58.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:47:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:47:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:01.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:02.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:02.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:03.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:03.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:03.852 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:03.852 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:03.852 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:03.886 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:06.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:06.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:07.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:07.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:08.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:09.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:09.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:13.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:13.853 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:13.854 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:13.854 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:13.888 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:15.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:15.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:17.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:17.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:18.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:18.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:18.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:20.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:20.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:23.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:23.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:23.523 [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:48:23.524 [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:48:23.854 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:23.854 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:23.854 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:23.889 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:24.055 [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:48:24.056 [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:48:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:24.548 [pool-4-thread-5] INFO i.d.c.cassandra.CommitLogProcessor - Processing commit log CommitLog-6-1587055325149.log 16:48:24.554 [pool-4-thread-5] DEBUG o.a.c.db.commitlog.CommitLogReader - Reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325149.log (CL version 6, messaging version 11, compression null) 16:48:24.724 [pool-4-thread-5] DEBUG o.a.c.db.commitlog.CommitLogReader - Finished reading /var/lib/cassandra/cdc_raw/CommitLog-6-1587055325149.log 16:48:24.724 [pool-4-thread-5] DEBUG i.d.connector.base.ChangeEventQueue - Enqueuing source record 'io.debezium.connector.cassandra.EOFEvent@6b95ea9a' 16:48:24.724 [pool-4-thread-5] INFO i.d.c.cassandra.CommitLogProcessor - Successfully processed commit log CommitLog-6-1587055325149.log 16:48:25.186 [kafka-producer-network-thread | producer-1] DEBUG o.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='null.keyspace1.standard1')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka1:9092 (id: 1 rack: null) 16:48:25.187 [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=[{name=null.keyspace1.standard1}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 6 to node 1 16:48:25.190 [kafka-producer-network-thread | producer-1] DEBUG o.a.k.c.p.internals.ProducerMetadata - [Producer clientId=producer-1] Removing unused topic null.keyspace1.standard1 from the metadata list, expiryMs 1587055705159 now 1587055705189 16:48:25.190 [kafka-producer-network-thread | producer-1] DEBUG org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Updated cluster metadata updateVersion 3 to MetadataCache{clusterId='iBAxSx52QtqPUKg4y6eePA', nodes=[kafka1:9092 (id: 1 rack: null)], partitions=[], controller=kafka1:9092 (id: 1 rack: null)} 16:48:25.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:25.492 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:25.492 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:25.518 [pool-3-thread-1] DEBUG i.d.c.cassandra.CommitLogUtil - Deleted commit log CommitLog-6-1587055325149.log in cdc directory 16:48:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:26.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:27.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:28.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:29.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:30.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:30.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:31.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:31.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:31.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:32.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:32.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:33.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:33.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:33.856 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:33.856 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:33.856 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:33.889 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:34.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:34.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:35.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:35.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:36.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:37.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:38.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:39.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:39.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:40.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:41.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:41.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:42.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:43.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:43.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:43.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:43.857 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:43.857 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:43.857 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:43.890 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:44.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:45.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:46.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:47.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:48.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:49.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:49.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:49.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:50.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:50.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:51.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:52.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:52.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:53.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:53.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:53.554 [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:48:53.556 [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:48:53.858 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:48:53.859 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:48:53.859 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:48:53.893 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:48:54.083 [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:48:54.084 [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:48:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:54.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:48:55.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:56.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:57.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:58.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:58.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:48:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:48:59.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:00.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:49:01.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:02.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:03.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:03.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:03.859 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:49:03.860 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:49:03.860 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:49:03.894 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:49:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:04.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:05.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:06.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:06.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:49:06.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:07.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:08.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:08.489 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:09.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:09.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:10.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:11.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:12.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:12.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:49:12.488 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:13.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:13.860 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:49:13.861 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:49:13.861 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:49:13.894 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:49:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:14.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:15.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:15.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:16.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:16.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:17.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:49:18.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:19.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:20.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:20.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:21.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:22.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:23.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit... 16:49:23.559 [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:49:23.561 [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:49:23.862 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Refreshing schemas... 16:49:23.862 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Updated schema for keyspace1.standard1 16:49:23.862 [pool-4-thread-4] DEBUG i.d.connector.cassandra.SchemaHolder - Schemas are refreshed 16:49:23.895 [pool-4-thread-3] DEBUG i.d.c.cassandra.SnapshotProcessor - Skipping snapshot [mode: INITIAL] 16:49:24.091 [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:49:24.093 [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:49:24.486 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - checking for more records... 16:49:24.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - polling records... 16:49:24.487 [pool-4-thread-2] DEBUG i.d.connector.base.ChangeEventQueue - no records available yet, sleeping a bit...